立即学习:https://edu.csdn.net/course/play/24458/296447?utm_source=blogtoedu

threading.Event事件

 

1.概念及功能：主要是完成线程之间的通信，将另一个线程的运行状态通知给另一个线程

 

2.使用场景：

1）客户端运行时等待服务器启动连接，若等待时间过长或者尝试连接次数过多，提示连接失败。只有等服务器启动事件成功后，才会进行连接事件

 

3.Event的相关属性

1）Event.wait():表示等待，括号里面可以加上特定的等待时间

2）Event.set（）：给等待发送一个信号，等待着的线程就会继续运行

3）clear:Event默认是False，当被set后为Ture，clear可以使得其重新设置为False

4)is_set():判断事件是否已经被set

 

4.代码

from threading import Thread,Event,currentThread
import time#创建事件对象
event = Event()
#创建客户端函数模拟客户端连接
def client():n = 0#设置等待取消的条件函数，如果尝试连接的次数超过5次，则退出等待，因为event.wait的时间是0.5，最多等5次，需要2.5秒，而在server中沉睡了5秒，因此会等不到event.set()的执行就退出等待while not event.is_set():if n == 5:print('%s is failed to connect the server')returnn += 1#这里需要注意return和break的区别，break只是跳出循环，而return是跳出函数，如果用break会使得返回连接成功的信息print('%s is trying to connect......'%currentThread().getName())print('*'*20,'%s第%s次尝试连接'%(currentThread().getName(),n),'*'*20)event.wait(0.5)#等待事件的发生，等待set#print('%s is connected'%currentThread().getName())#创建服务端函数模拟服务器
def server():print("%s is trying to start"%currentThread().getName())time.sleep(3)event.set()if __name__ == '__main__':for i in range(3):c = Thread(target=client)c.start()s = Thread(target=server)s.start()