В питоновой асинхронщине есть asyncio.Event
, который позволяет уведомить соседний таск о каком-нибудь событии:
import asyncio
event = asyncio.Event()
async def task1():
event.set()
async def task2():
while True:
await event.wait()
event.clear()
# do_some_work()
Однако для тех же задач можно попробовать использовать и просто asyncio.Future
:
import asyncio
event = asyncio.Future()
async def task1():
if not event.done():
event.set_result(True)
async def task2():
global event
while True:
await event
event = asyncio.Future() # clear
# do_some_work()
Эти примеры на первый взгляд эквивалентны и работают одинаково.
Но, заглянув в реализацию threading.Event, я увидел, что там используется несколько футур в self._waiters = collections.deque()
, и для каждого ожидающего создаётся своя отдельная футура.
Однако ведь вроде можно await'ить одну и ту же футуру несколько раз. Значит, для всех ожидающих достаточно одной футуры.
Или нельзя?
Короче, зачем asyncio.Event
устроен так сложно? Зачем в нём deque и несколько футур? На какие грабли я рискую напороться, если вместо asyncio.Event
буду использовать одну-единственную футуру, как во втором примере?