成都网站建设设计

将想法与焦点和您一起共享

创新互联Python教程:Python如何实现线程条件同步

目前创新互联建站已为上千多家的企业提供了网站建设、域名、网页空间、网站托管维护、企业网站设计、耒阳网站维护等服务,公司将坚持客户导向、应用为本的策略,正道将秉承"和谐、参与、激情"的文化,与客户和合作伙伴齐心协力一起成长,共同发展。

同步条件

条件同步和条件变量同步差不多意思,只是少了锁功能,因为条件同步设计于不访问共享资源的条件环境。event=threading.Event():条件环境对象,初始值 为False;

event.isSet():返回event的状态值;

event.wait():如果 event.isSet()==False将阻塞线程;

event.set(): 设置event的状态值为True,所有阻塞池的线程激活进入就绪状态, 等待操作系统调度;

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

相关推荐:《python视频教程》

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如何实现条件变量同步


本文名称:创新互联Python教程:Python如何实现线程条件同步
路径分享:https://chengdu.cdxwcx.cn/article/cdppdsd.html