07.07自我总结

Event事件

一.导入模块

from threading import Event

二.概念

线程间状态同步:即将一个任务丢到子进程中,这个任务将异步执行,如何获取到这个任务的执行状态

**注意:**执行状态和执行结果不是同一个概念,异步回调拿到的是任务的执行结果

假设

一个线程 负责启动服务器 启动服务器需要花一定的时间

另一个线程作为客户端 要连接服务器 必须保证服务器已经启动

要获取状态可以采永轮询(循环轮训)的方法 但是浪费了CPU资源 而且可能会造成延迟 不能立即获取状态

就可以使用事件来完成状态同步

**事件本质就是 一个标志 可以是False 或是True **

特殊之处在于 其包含一个wait函数 可以阻塞当前线程 直到状态从False变为True

三.Event对象的方法

• event.isSet()：返回event的状态值
• event.wait()：将阻塞线程；知道event的状态为True,会执行下去
• event.set()： 设置event的状态值为True，所有阻塞池的线程激活进入就绪状态， 等待操作系统调度
• event.clear()：恢复event的状态值为False。

四.简单应用

1from threading import Thread,Event
2import time
3
4
5e = Event() #默认值为false
6
7#启动服务器任务
8def start_server():
9
10    print('starting server....')
11	#模拟启动服务器的延迟
12    time.sleep(3)
13
14    print('server started....')
15    
16	#将event事件的初始状态由false转为true
17    e.set()
18
19#连接服务器任务
20def connect_server():
21    e.wait()    #等待start事件的任务状态从false变为true
22
23    if e.is_set():
24        print('服务器连接成功')
25
26#创建线程对象
27t1 = Thread(target=start_server)
28t2 = Thread(target=connect_server)
29
30#启动线程
31t1.start()
32t2.start()

本文分享 CNBlog - 加载时间中.....。
如有侵权，请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”，欢迎正在阅读的你也加入，一起分享。