导语:
本文主要介绍了关于Python如何实现线程条件同步的相关知识,希望可以帮到处于编程学习途中的小伙伴
同步条件
条件同步与条件变量同步类似,只是少了锁功能,因为条件同步是在不访问共享资源的条件环境下设计的。 event=threading.Event():条件环境对象,初始值为False;
event.isSet():返回event的状态值;
event.wait():如果 event.isSet()==False将阻塞线程;
event.set():设置事件的状态值为True,阻塞池中的所有线程都被激活,进入就绪状态,等待操作系统调度;
event.clear():恢复event的状态值为False。
import threading, time
class Boss(threading.Thread):
def run(self):
print("BOSS: 今晚大家加班")
event.isSet() or event.set()
time.sleep(5)
print("BOSS: 大家可以下班了")
event.isSet() or event.set()
class Worker(threading.Thread):
def run(self):
event.wait()
print("Worker: 唉。。。。")
time.sleep(0.25)
event.clear()
event.wait()
print("Worker: Great!")
if __name__ == "__main__":
event = threading.Event()
threads = []
for i in range(5):
threads.append(Worker())
threads.append(Boss())
for t in threads:
t.start()
for t in threads:
t.join()
运行结果:
BOSS: 今晚大家加班
Worker: 唉。。。。
Worker: 唉。。。。
Worker: 唉。。。。
Worker: 唉。。。。
Worker: 唉。。。。
BOSS: 大家可以下班了
Worker: Great!
Worker: Great!
Worker: Great!
Worker: Great!
Worker: Great!
本文为原创文章,版权归知行编程网所有,欢迎分享本文,转载请保留出处!
你可能也喜欢
- ♥ 如何跳过python错误?11/01
- ♥ python可以用作网站吗?10/04
- ♥ Python 解释器如何读取源文件12/03
- ♥ python检查列表值是否为空09/23
- ♥ 如何读取python中某些行的内容11/10
- ♥ 如何在python中实例化ChainMap01/09
内容反馈