await
заставляет ожидать завершения всей функции и только потом происходит переход к следующей итерации.asyncio.create_task
, то создается и запускается фоновая задача - цикл продолжается после запуска этой асинхронной функции и не ждет ее завершения.хотя в функции pool_user нет ничего, что могло бы блокировать асинхронный цикл
if await user.connect()
await bot.send_message
text=client2.recv(1024).decode('utf-8')
print(text)
channel = await get_channel()
exchange = await channel.declare_exchange(
"direct", auto_delete=True
)
queue = await channel.declare_queue(
consumer, auto_delete=True
)
await message.ack()
)