python 多线程系列—Event 对象 (六)

本贴最后更新于 581 天前,其中的信息可能已经天翻地覆

一、Event对象

1、threading.Event 事件对象 用于线程之间的简单通信,一个线程发出事件信号,其他线程等待该信号。
1、Event对象set()方法可以设置Event对象内部的信号标志为True,并通知所有处于等待阻塞状态的线程恢复运行状态
2、Event对象clear()方法可以清除Event对象内部信号标识,将其设置为False
3、Event的isSet()方法用来判断内部信号的标识状态
4、Event对象的wait()方法只有在内部信号状态为True时很快的执行并返回
5、Event对象内部信号标识为False,wait()方法将阻塞线程一致等待至超时,或者内部信号为真才返回

二、代码演示

信号标识为False,线程进入等待状,等到下一个线程将信号标识修改为True,等待的线程将恢复执行

import threading
class Demo(threading.Thread):
    def __init__(self,my_event):
        super().__init__()
        self.lock = threading.Lock()
        #event事件
        self.my_event = my_event

    def run(self) -> None:
        #这要加锁,避免2个线程同时修改信号标识的情况,加了锁就变成了单线程了
        # 获取线程名称
        thread_name = self.getName()
        with self.lock:
            if self.my_event.isSet():
                #如果信号标识是True,则将信号标识改为False
                self.my_event.clear()
                print(f"运动员{thread_name}等待起跑命令")
                self.my_event.wait()
                print(f"运动员{thread_name}收到起跑命令,开始跑步")
            else:
                #如果信号标识为False,则将信号标识设置为True
                self.my_event.set()
                print(f"运动员{thread_name}无需等待,开始跑步")

if __name__ == '__main__':
    my_event = threading.Event()
    #设置初始值
    my_event.set()
    for i in range(20):
        th = Demo(my_event=my_event)
        th.start()
2 回帖
请输入回帖内容 ...
  • xiu

    无需等待开始打扣👍

  • 其他回帖
  • AMuBai

    涨知识了!!!666!!!