Python多线程如何实现事件驱动 Python多线程事件监听机制解析

import threading
import time
<h1>共享事件对象</h1><p>event = threading.Event()</p><p>def listener():
print("监听线程启动，等待事件...")
event.wait()  # 阻塞直到事件被set
print("事件已被触发，开始处理...")</p><p>def trigger():
time.sleep(2)
print("触发事件")
event.set()  # 触发事件，唤醒wait()</p><h1>创建并启动线程</h1><p>t1 = threading.Thread(target=listener)
t2 = threading.Thread(target=trigger)</p><p>t1.start()
t2.start()</p><p>t1.join()
t2.join()

import threading
import queue
import time
<p>event_queue = queue.Queue()</p><p>def event_producer(name):
for i in range(3):
event = {'type': 'data', 'source': name, 'value': i}
event_queue.put(event)
print(f"{name} 发布事件: {event}")
time.sleep(1)</p><p>def event_consumer():
while True:
event = event_queue.get()
if event is None:  # 结束信号
break
print(f"处理事件: {event}")
event_queue.task_done()</p><h1>启动消费者线程</h1><p>consumer_thread = threading.Thread(target=event_consumer, daemon=True)
consumer_thread.start()</p><h1>启动多个生产者</h1><p>threads = []
for name in ['sensor_A', 'sensor_B']:
t = threading.Thread(target=event_producer, args=(name,))
t.start()
threads.append(t)</p><h1>等待所有生产者完成</h1><p>for t in threads:
t.join()</p><h1>发送结束信号</h1><p>event_queue.put(None)
consumer_thread.join()

import threading
<p>condition = threading.Condition()
ready = False</p><p>def worker():
with condition:
print("工作线程等待准备信号...")
while not ready:
condition.wait()
print("开始执行任务！")</p><p>def coordinator():
global ready
with condition:
print("协调线程准备资源...")
time.sleep(2)
ready = True
condition.notify_all()  # 通知所有等待线程