十年网站开发经验 + 多家企业客户 + 靠谱的建站团队
量身定制 + 运营维护+专业推广+无忧售后,网站问题一站解决
这篇文章将为大家详细讲解有关Python实现线程条件同步的方法,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。
创新互联专注于无锡网站建设服务及定制,我们拥有丰富的企业做网站经验。 热诚为您提供无锡营销型网站建设,无锡网站制作、无锡网页设计、无锡网站官网定制、微信小程序定制开发服务,打造无锡网络公司原创品牌,更为您提供无锡网站排名全网营销落地服务。
同步条件
条件同步和条件变量同步差不多意思,只是少了锁功能,因为条件同步设计于不访问共享资源的条件环境。event=threading.Event():条件环境对象,初始值 为False;
event.isSet():返回event的状态值;
event.wait():如果 event.isSet()==False将阻塞线程;
event.set(): 设置event的状态值为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实现线程条件同步的方法就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。