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。

四.简单应用

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

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