У меня есть получатель сообщений веб-сокета, который выглядит следующим образом:
async def consumer_handler(websocket, path):
async for message in websocket:
await consumer(message)
К сожалению, мой consumer() довольно затратен в вычислительном отношении, поэтому я не успеваю за сообщениями.В идеале я хотел бы использовать что-то вроде ProcessPoolExecutor для параллельного выполнения этих вычислений, но я не уверен, как в структуре async / await, описанной выше.