我正在尝试使用asyncio/aioamqp编写一个异步消费者。我的问题是，回调协程(下方)正在阻塞。我将channel设置为执行basic_consume()，并将回调分配为callback()。回调有一个“yieldfromasyncio.sleep”语句(模拟“工作”)，它从发布者那里获取一个整数并在打印消息之前休眠一段时间。如果我发布两条消息，一条时间为“10”，紧接着一条时间为“1”，我预计第二条消息会先打印，因为它的休眠时间较短。相反，回调会阻塞10秒，打印第一条消息，然后打印第二条消息。似乎basic_consume或回调在某处阻塞。有没有其他方法可以解决这个问题？@as