Python实现线程条件同步的方法
这篇文章将为大家详细讲解有关Python实现线程条件同步的方法,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。
同步条件
条件同步和条件变量同步差不多意思,只是少了锁功能,因为条件同步设计于不访问共享资源的条件环境。event=threading.Event():条件环境对象,初始值 为False;
event.isSet():返回event的状态值;
event.wait():如果 event.isSet()==False将阻塞线程;
event.set(): 设置event的状态值为True,所有阻塞池的线程激活进入就绪状态, 等待操作系统调度;
event.clear():恢复event的状态值为False。
importthreading,timeclassBoss(threading.Thread):defrun(self):print("BOSS:今晚大家加班")event.isSet()orevent.set()time.sleep(5)print("BOSS:大家可以下班了")event.isSet()orevent.set()classWorker(threading.Thread):defrun(self):event.wait()print("Worker:唉。。。。")time.sleep(0.25)event.clear()event.wait()print("Worker:Great!")if__name__=="__main__":event=threading.Event()threads=[]foriinrange(5):threads.append(Worker())threads.append(Boss())fortinthreads:t.start()fortinthreads:t.join()
运行结果:
BOSS:今晚大家加班Worker:唉。。。。Worker:唉。。。。Worker:唉。。。。Worker:唉。。。。Worker:唉。。。。BOSS:大家可以下班了Worker:Great!Worker:Great!Worker:Great!Worker:Great!Worker:Great!
关于Python实现线程条件同步的方法就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。
声明:本站所有文章资源内容,如无特殊说明或标注,均为采集网络资源。如若本站内容侵犯了原著者的合法权益,可联系本站删除。