Связь между асинхронными задачами и синхронными потоками в Python ⇐ Python

[Anonymous]

Я ищу лучшее решение для связи между асинхронными задачами и методами/функциями, которые выполняются в исполнителе пула потоков из concurrent.futures. В предыдущих синхронных проектах я использовал класс очереди.Queue. Я предполагаю, что любой метод должен быть потокобезопасным, и поэтому asyncio.queue не будет работать.

Я видел, как люди расширяли класс очереди.Queue, чтобы сделать что-то вроде:

Код: Выделить всё

class async_queue(Queue):
async def aput(self, item):
self.put_nowait(item)

async def aget(self):
resp = await asyncio.get_event_loop().run_in_executor( None, self.get )
return resp

Есть ли лучший способ?

Подробнее здесь: https://stackoverflow.com/questions/596 ... -in-python