threading.event是python中用于线程同步的标志机制,通过set()触发、clear()重置、wait()阻塞等待,实现线程间的启动控制与状态协调。

Python3 中的 threading.Event 是一种线程间通信机制,用于控制一个或多个线程等待某个条件成立后再继续执行。它就像一个“标志”,可以被设置(set)或清除(clear),其他线程可以根据这个标志的状态来决定是否阻塞或运行。
Event 的基本用法
Event 提供了几个关键方法:
- wait():线程会在此处暂停,直到事件被设置为“已触发”状态。如果事件已经处于触发状态,调用 wait() 会立即返回。
- set():将事件设置为“已触发”状态,所有正在 wait() 的线程会被唤醒。
- clear():将事件重置为“未触发”状态,后续的 wait() 调用将会阻塞。
- is_set():返回事件当前是否处于“已触发”状态,True 表示已触发,False 表示未触发。
简单示例:主线程通知子线程开始工作
下面是一个典型的使用场景:一个工作线程等待启动信号,主线程在准备完成后发出信号。
import threading
import time
<p>def worker(event):
print("worker: 正在等待启动信号...")
event.wait() # 阻塞直到收到信号
print("worker: 收到信号,开始工作!")
time.sleep(2)
print("worker: 工作完成")</p><h1>创建事件对象</h1><p>start_event = threading.Event()</p><p><span>立即学习</span>“<a href="https://pan.quark.cn/s/00968c3c2c15" style="text-decoration: underline !important; color: blue; font-weight: bolder;" rel="nofollow" target="_blank">Python免费学习笔记(深入)</a>”;</p><div class="aritcle_card flexRow">
<div class="artcardd flexRow">
<a class="aritcle_card_img" href="/ai/968" title="AMiner"><img
src="https://img.php.cn/upload/ai_manual/000/000/000/175680173468538.png" alt="AMiner" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
<div class="aritcle_card_info flexColumn">
<a href="/ai/968" title="AMiner">AMiner</a>
<p>AMiner——新一代智能型科技情报挖掘与服务系统,能够为你提供查找论文、理解论文、分析论文、写作论文四位一体一站式服务。</p>
</div>
<a href="/ai/968" title="AMiner" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span> </a>
</div>
</div><h1>创建并启动工作线程</h1><p>t = threading.Thread(target=worker, args=(start_event,))
t.start()</p><p>print("main: 准备中...")
time.sleep(3)
print("main: 准备完成,发送启动信号")
start_event.set() # 触发事件,唤醒 worker</p><p>t.join()
print("全部完成")</p>实际应用场景
Event 常用于以下情况:
- 启动同步:多个工作线程同时等待一个信号,实现“统一启动”效果,比如性能测试中模拟并发请求。
- 暂停/恢复:用 Event 控制线程是否继续运行,例如实现一个可暂停的任务循环。
- 任务协调:一个线程完成某阶段后通知另一个线程继续处理。
比如实现一个持续工作的线程,可通过 Event 控制其运行与暂停:
import threading
import time
<p>def runner(event):
while True:
if event.is_set():
print("runner: 正在运行")
else:
print("runner: 暂停中...")
time.sleep(1)</p><p>pause_event = threading.Event()
pause_event.set() # 初始为运行状态</p><p>t = threading.Thread(target=runner, args=(pause_event,), daemon=True)
t.start()</p><p>time.sleep(3)
pause_event.clear() # 暂停
time.sleep(3)
pause_event.set() # 恢复</p><p>time.sleep(2)</p>基本上就这些。Event 使用简单,适合做线程间的开关控制,不复杂但容易忽略细节,比如忘记 set() 会导致死锁等待。合理使用能有效简化线程协作逻辑。









