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。
四.简单应用
代码语言:javascript复制from threading import Thread,Event
import time
e = Event() #默认值为false
#启动服务器任务
def start_server():
print('starting server....')
#模拟启动服务器的延迟
time.sleep(3)
print('server started....')
#将event事件的初始状态由false转为true
e.set()
#连接服务器任务
def connect_server():
e.wait() #等待start事件的任务状态从false变为true
if e.is_set():
print('服务器连接成功')
#创建线程对象
t1 = Thread(target=start_server)
t2 = Thread(target=connect_server)
#启动线程
t1.start()
t2.start()