一、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()
欢迎来到testingpai.com!
注册 关于