在 Python 中，`threading.Event` 是一个用于线程间通信的同步原语。它允许一个或多个线程等待某个特定条件的发生。`Event` 对象维护一个内部标志（flag），可以通过 `set()` 方法将其设为 `True`，也可以通过 `clear()` 方法将其重置为 `False`。线程可以使用 `wait()` 方法阻塞，直到该标志被设置为 `True`。 ### 基本用法示例 以下是一个简单的 `threading.Event` 使用示例，演示了如何创建事件、设置和清除事件标志，并在线程中等待事件触发： ```python import threading import time # 事件对象 event = threading.Event() def wait_for_event(): print("等待事件触发...") event.wait() # 阻塞直到事件被设置 print("事件已被触发！") # 创建线程 t = threading.Thread(target=wait_for_event) t.start() # 主线程休眠一段时间后触发事件 time.sleep(2) print("准备触发事件...") event.set() # 等待子线程完成 t.join() ``` ### `set()` 和 `clear()` 的作用 - `event.set()`：将事件的内部标志设为 `True`，所有调用 `wait()` 并正在等待的线程将被唤醒。 - `event.clear()`：将事件的内部标志重置为 `False`，后续调用 `wait()` 的线程将继续阻塞，直到下一次 `set()` 被调用。 例如，在某些场景中，可能需要重复使用同一个事件进行多次通知： ```python import threading import time event = threading.Event() def repeat_wait(): while True: print("等待下一次触发...") event.wait() print("触发发生！") event.clear() # 清除标志以等待下一次触发 t = threading.Thread(target=repeat_wait) t.start() for i in range(3): time.sleep(1) print(f"第 {i+1} 次触发") event.set() t.join() ``` ### `wait(timeout=None)` 的行为 `wait()` 方法支持可选的超时参数 `timeout`。如果指定了超时时间，则线程将在最多等待指定秒数后自动恢复执行，而不必等到事件被设置。 ```python def wait_with_timeout(): print("开始等待，最多 3 秒") result = event.wait(timeout=3) if result: print("事件在等待期间被触发") else: print("等待超时，事件未被触发") t = threading.Thread(target=wait_with_timeout) t.start() time.sleep(1) # 不触发事件 t.join() ``` 在这个例子中，由于没有调用 `event.set()`，`wait()` 将在 3 秒后超时并返回 `False`。 ### 总结 `threading.Event` 是一种轻量级的线程同步机制，适用于一个或多个线程等待某个条件成立的场景。其核心方法包括： - `set()`：激活事件，释放所有等待的线程。 - `clear()`：重置事件状态，使后续的 `wait()` 再次阻塞。 - `wait(timeout)`：阻塞当前线程，直到事件被激活或达到指定的超时时间。