python教程分享python中Event实现线程间同步介绍

前言：

event在python线程间同步是一种常用的方法，本博客以生产者线程和工作者线程为例说明event在线程间进行10次同步的应用。

import threading
from threading import event, thread
import time
import random
from time import sleep
 
pevent = event() #默认是没有事件的
pevent.clear()
 
cevent = event() 
cevent.clear()
 
runtimes = 10
mutex_lock = threading.lock()
 
 
class producerthread (threading.thread):
    def __init__(self, name, runflag):
        threading.thread.__init__(self)
        self.name = name
        self.runflag = runflag
        self.cOntinueflag= event()
        self.continueflag.set()
        
    def run(self):
        global runtimes  
        sleep(1)
        print ("开始线程：" + self.name)
        while self.continueflag.isset():
            print("wait consumer &＃8230;")
            if runtimes == 0:
                self.continueflag.clear()
                break
            pevent.wait()
            print("come an consumer &＃8230;")
            mutex_lock.acquire()
            runtimes = runtimes &＃8211; 1
            mutex_lock.release()
            pevent.clear()
            sleep(1)
            cevent.set()
        print ("退出线程：" + self.name)
        self.runflag.set()
 
class consumerthread (threading.thread):
    def __init__(self,name, runflag):
        threading.thread.__init__(self)
        self.name = name
        self.runflag = runflag
        self.cOntinueflag= event()
        self.continueflag.set()
        
    def run(self):
        global runtimes 
        print ("开始线程：" + self.name)
        while self.continueflag.isset():
            if 0 == runtimes:
                self.continueflag.clear() 
                pevent.set()
                break
            print("i want to consum &＃8230; ", runtimes)
            pevent.set() #通知生产者要消费
            cevent.wait()
            cevent.clear()
            sleep(1)
        print ("退出线程：" + self.name)
        self.runflag.set()
 
def test_pthread():
    runflag = event() 
    pt = producerthread("producer", runflag)
    ct = consumerthread("consumer", runflag)
    pt.start()
    ct.start()
    pt.join()
    ct.join()
    runflag.wait()
 
if __name__ == &＃39;__main__&＃39;:
    print(&＃39;===============begin=================&＃39;)
    test_pthread()
    print(&＃39;===============end=================&＃39;)

运行结果如下：

需要了解更多python教程分享python中Event实现线程间同步介绍，都可以关注python教程分享栏目&＃8212;编程笔记