How can I use asyncio for message passing in Python?

How can I use asyncio for message passing in Python?

You can use asyncio's Queue for message passing between coroutines. Would you like a code example?

Yes, please provide a code example.

Here's a simple example:

import asyncio

async def producer(queue):
    for i in range(5):
        await queue.put(i)
        print(f'Produced {i}')
        await asyncio.sleep(1)

async def consumer(queue):
    while True:
        item = await queue.get()
        print(f'Consumed {item}')
        queue.task_done()

async def main():
    queue = asyncio.Queue()
    await asyncio.gather(producer(queue), consumer(queue))

asyncio.run(main())

What does this code do?

This code creates a producer that generates numbers and a consumer that processes them using an asyncio Queue.