Python 线程：Event.set() 真的会通知每个等待线程吗

Question

如果我有一个 threading.Event 和以下两行代码：

event.set()
event.clear()

并且我有一些正在等待该事件的线程。

我的问题与调用 set() 方法时发生的情况有关：

• 我可以绝对确定所有等待线程都会收到通知吗？ （即 Event.set()“通知”线程）
• 或者这两行执行得如此之快，以至于某些线程可能仍在等待？ （即 Event.wait() 轮询事件的状态，该状态可能已经再次“清除”）

感谢您的回答！

Answer 1

在 Python 的内部，事件是通过 Condition()< 实现的/code>对象。

调用 event.set() 方法时， 条件的notify_all()被调用（拿到锁后一定要保证不被中断），那么所有线程都会收到通知（只有当所有线程都获得锁后才会释放锁）线程被通知），因此您可以确保所有线程都将有效地被通知。

现在，在通知之后清除事件不是问题......直到您不想使用 event.is_set() 检查等待线程中的事件值，但您只需要这种检查是否等待超时。

示例：

有效的伪代码：

#in main thread
event = Event()
thread1(event)
thread2(event)
...
event.set()
event.clear()

#in thread code
...
event.wait()
#do the stuff

可能无效的伪代码：

#in main thread
event = Event()
thread1(event)
thread2(event)
...
event.set()
event.clear()

#in thread code
...
while not event.is_set():
   event.wait(timeout_value)
#do the stuff

编辑： 在 python >= 2.7 中，您仍然可以等待超时事件并确定事件的状态：

event_state = event.wait(timeout)
while not event_state:
    event_state = event.wait(timeout)

Answer 2

验证事情是否按预期工作很容易（注意：这是 Python 2 代码，需要针对 Python 3 进行调整）：

import threading

e = threading.Event()
threads = []

def runner():
    tname = threading.current_thread().name
    print 'Thread waiting for event: %s' % tname
    e.wait()
    print 'Thread got event: %s' % tname

for t in range(100):
    t = threading.Thread(target=runner)
    threads.append(t)
    t.start()

raw_input('Press enter to set and clear the event:')
e.set()
e.clear()
for t in threads:
    t.join()
print 'All done.'

如果运行上面的脚本并且它终止，则一切都应该很好： -) 注意有一百个线程正在等待事件被设置；它立即被设置和清除；所有线程都应该看到这一点并且应该终止（尽管不是以任何明确的顺序，并且“All done”可以在“Press Enter”提示之后的任何地方打印，而不仅仅是在最后。

Answer 3

Python 3+

更容易检查它是否有效

import threading
import time

lock = threading.Lock() # just to sync printing
e = threading.Event()
threads = []

def runner():
    tname = threading.current_thread().name
    with lock:
        print('Thread waiting for event ', tname)
    e.wait()
    with lock:
        print('Thread got event: ', tname)

for t in range(8): # Create 8 threads could be 100's
    t = threading.Thread(target=runner)
    threads.append(t)
    t.start()

time.sleep(1) # force wait until set/clear
e.set()
e.clear()
for t in threads:
    t.join()    
    
print('Done')