### Python Threading Module 中 Event 对象的用法 在Python中，`threading.Event` 是一个多线程编程中的同步原语，允许一个线程向其他线程发送简单的信号。这个对象提供了一种简单的方式来进行线程间的通信。 #### 创建和初始化 Event 对象 创建 `Event` 实例非常直观： ```python from threading import Event event = Event() ``` 默认情况下，内部旗标被设为假（即未设置状态），可以显式调用 `.clear()` 方法来重置此旗标[^2]。 #### 设置和清除事件 可以通过调用 `set()` 来将内部旗标设置为真，表示发生了某个条件或达到了特定的状态；相反地，使用 `clear()` 可以将其重新设定回假值，表明当前不再满足之前所代表的那个条件[^3]。 #### 等待事件发生 另一个重要的功能就是让某些线程暂停执行并等待直到收到相应的通知为止——这正是通过 `wait(timeout=None)` 完成的工作。如果没有给出超时参数，则一直等到有人设置了该事件；如果有指定时间期限，在这段时间内如果没有得到通知就会返回False[^4]。 下面是一个完整的例子展示如何利用这些特性在线程之间传递消息： ```python import logging from time import sleep from threading import Thread, Event def sender(event_obj): logger.info('Sender is preparing to send an event...') sleep(5) # Simulate some work being done before sending the signal. data_to_send = {'flag': 'ok'} logger.info(f'Sending event with data: {data_to_send}') event_obj.set() def receiver(name, event_obj): logger.info(f'{name} waiting for event.') event_obj.wait() # Wait until the flag becomes true or timeout occurs. if event_obj.is_set(): logger.info(f"{name} received the event.") else: logger.warning(f"{name}'s wait timed out.") if __name__ == '__main__': logging.basicConfig(level=logging.INFO, format='%(asctime)s %(message)s', datefmt='%Y-%m-%d %H:%M:%S') e = Event() r1 = Thread(target=receiver, args=('Receiver 1', e)) r2 = Thread(target=receiver, args=('Receiver 2', e)) s = Thread(target=sender, args=(e,)) r1.start();r2.start(); s.start(); r1.join();r2.join(); s.join() ``` 这段代码展示了两个接收者线程启动后立即进入等待状态，而发送方经过一段时间模拟工作完成后发出事件通知给所有监听它的接收者们。这里还加入了日志记录以便更好地理解程序流程。