在 Python 中，可以使用 `threading` 模块中的 `Event` 类来实现线程间的通信。通过事件对象，可以在线程中监听某个条件是否满足，并根据该条件来控制主线程的退出。 以下是一个示例，展示如何创建一个线程来监听事件，并在满足条件时结束主线程： ```python import threading import time # 创建一个事件对象 event = threading.Event() def wait_for_event(): print("等待事件被触发...") event.wait() # 阻塞直到事件被设置 print("事件被触发，线程任务完成。") def trigger_event_after(seconds): print(f"将在 {seconds} 秒后触发事件...") time.sleep(seconds) event.set() # 设置事件，释放所有等待的线程 if __name__ == "__main__": # 创建监听事件的线程 listener_thread = threading.Thread(target=wait_for_event) listener_thread.start() # 创建触发事件的线程 trigger_thread = threading.Thread(target=trigger_event_after, args=(5,)) trigger_thread.start() # 等待监听线程完成 listener_thread.join() # 主线程结束前检查事件是否已触发 if event.is_set(): print("主线程即将结束。") ``` ### 代码说明： 1. **`event = threading.Event()`** 创建了一个事件对象，它提供了 `wait()` 和 `set()` 方法来控制线程的同步。 2. **`event.wait()`** 会阻塞当前线程（在这个例子中是 `listener_thread`），直到事件被设置为“已触发”状态。 3. **`event.set()`** 用于触发事件，释放所有等待该事件的线程。 4. **`event.is_set()`** 可以用来检查事件是否已经被触发。 ### 程序流程： - 主线程启动两个子线程：一个用于监听事件，另一个用于在指定时间后触发事件。 - `wait_for_event()` 函数中的线程会一直等待事件被触发。 - `trigger_event_after()` 函数中的线程会在指定的延迟后调用 `event.set()` 来触发事件。 - 一旦事件被触发，`wait_for_event()` 中的 `event.wait()` 将不再阻塞，线程继续执行并结束。 - 主线程通过 `listener_thread.join()` 等待监听线程完成，然后检查事件是否已触发并结束。 ### 线程安全与注意事项： - 如果需要在多个线程之间共享资源或状态，应使用 `threading.Lock` 或其他同步机制来避免竞态条件。 - 事件对象是线程安全的，可以在多个线程中使用。 - 在实际应用中，事件的触发条件可以基于外部输入（如网络请求、文件变化、用户操作等）。 ### 示例扩展： 如果需要在满足特定条件时主动结束主线程，可以在主线程中加入条件判断逻辑。例如，当某个变量被修改或某个事件被触发时，主线程可以退出： ```python import threading import time event = threading.Event() def monitor_condition(): time.sleep(3) # 模拟条件延迟 print("条件已满足，触发事件") event.set() if __name__ == "__main__": monitor_thread = threading.Thread(target=monitor_condition) monitor_thread.start() print("主线程等待条件满足...") event.wait() # 阻塞直到事件被触发 print("条件满足，主线程即将结束") ``` 在这个示例中，主线程会一直等待事件被触发，一旦事件被触发，主线程将继续执行并结束。 ---