同步条件

由于条件同步设计在不访问共享资源的条件环境中，条件同步和条件变量同步几乎意味着没有锁定功能。event=threading.Event()：环境对象的条件、初始值 False；

event.isSet()：返回event的状态值；

event.wait()：如果 event.isSet()==False将阻塞线程；

event.set()： 设置event的状态值为true，所有阻塞池的线程激活到就绪状态， 等待操作系统调度；

event.clear()：False恢复event的状态值。

相关推荐:Python视频教程

importthreading,time
classBoss(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如何实现条件变量同步