задача через loop.run_in_executor(ThreadPoolExecutor(), ...)
после выполнения задачи нужно установить Event, который ожидает другой кусок асинк кода
в доке написано:
class asyncio.Event(*, loop=None)
An event object. Not thread-safe.
можно ли использовать asyncio.Event если он не потокобезопасный? или нужно юзать threading.Event? если второй, то как его ожидать в асинк коде?
Ну а зачем тебе потокобезопасность внутри одного лупа? Ты же будет асинк эвент дергать из других потоков, да? А вообще, тебе точно нужен эвент? Обычными эвейтами и газерами не обойтись?
то есть ничего страшного если запускаю в ThreadPoolExecutor? в разных местах вызываются, поэтому эвэйтом не получается.
Обсуждают сегодня