Python threading.Event () - Обеспечение пробуждения всех ожидающих потоков на event.set ()

У меня есть несколько потоков, которые ждут события, выполняют какое-то действие, а затем снова ждут события. Другой поток вызовет событие, когда это будет уместно.

Я не могу найти способ гарантировать, что каждый ожидающий поток срабатывает ровно один раз после установки события. В настоящее время у меня есть триггерный поток, установил его, поспал немного, затем очистил К сожалению, это приводит к тому, что ожидающие потоки захватывают заданное событие много раз или вообще ничего.

Я не могу просто заставить инициирующий поток порождать потоки ответов, чтобы запускать их один раз, потому что они являются ответами на запросы, сделанные из других источников.

Короче говоря: в Python, как поток может установить событие и убедиться, что каждый ожидающий поток воздействует на событие ровно один раз до его очистки?

Обновление:

I ' мы пытались настроить его, используя блокировку и очередь, но это не работает. Вот что у меня есть:

# Globals - used to synch threads
waitingOnEvent = Queue.Queue
MainEvent = threading.Event()
MainEvent.clear()    # Not sure this is necessary, but figured I'd be safe
mainLock = threading.Lock()

def waitCall():
    mainLock.acquire()
    waitingOnEvent.put("waiting")
    mainLock.release()
    MainEvent.wait()
    waitingOnEvent.get(False)
    waitingOnEvent.task_done()
    #do stuff
    return

def triggerCall():
    mainLock.acquire()
    itemsinq = waitingOnEvent.qsize()
    MainEvent.set()
    waitingOnEvent.join()
    MainEvent.clear()
    mainLock.release()
    return

В первый раз itemsinq правильно отображает, сколько вызовов ожидает, но только первый ожидающий поток, который совершит вызов, пройдет через них. С этого момента itemsinq всегда равен 1, и ожидающие потоки сменяются; каждый раз, когда происходит триггерный вызов, происходит следующее.

Обновление 2 Похоже, что только один из потоков event.wait () пробуждается , и все же queue.join () работает. Это говорит мне о том, что один ожидающий поток просыпается, захватывает из очереди и вызывает task_done (), а тот единственный get () / task_done () каким-то образом очищает очередь и разрешает join (). Затем триггерный поток завершает join (), очищает событие и, таким образом, предотвращает прохождение других ожидающих потоков. Почему очередь регистрируется как пустая / завершенная только после одного вызова get / task_done?

Кажется, что просыпается только один, даже если я закомментирую queue.get () и queue.task_done () и повесю триггер, поэтому он не может очистить событие.