在Python中,可以使用asyncio模块中的函数来等待消息的到来。以下是使用asyncio模块中的asyncio.Queue类来等待消息的示例代码:
import asyncio
async def waiting_for_message(queue):
while True:
message = await queue.get()
print('Received:', message)
async def main():
queue = asyncio.Queue()
task = asyncio.create_task(waiting_for_message(queue))
await queue.put('Hello')
await queue.put('World')
await task
asyncio.run(main())
在上面的代码中,waiting_for_message()函数是用来等待消息的,并通过asyncio模块中的Queue来实现。在main()函数中,我们首先创建了一个asyncio.Queue对象,然后使用create_task()函数来创建一个任务,并将其添加到事件循环中。接着,我们使用put()函数向队列中添加两个消息。最后,我们等待任务完成,以确保所有的消息都已处理完毕。
在等待消息的过程中,我们可以执行其他异步操作,例如发送消息、处理数据等等。