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()