How can I use asyncio.Queue in Python?

How can I use asyncio.Queue in Python?

You can use asyncio.Queue to manage a queue of tasks in an asynchronous environment. It allows you to add and remove items in a thread-safe manner.

Can you show me a simple example of how to implement it?

Sure! Here's a basic example:

import asyncio

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

async def main():
    queue = asyncio.Queue()
    for i in range(5):
        await queue.put(i)

    # Start workers
    workers = [asyncio.create_task(worker(queue)) for _ in range(2)]
    await queue.join()  # Wait until all items are processed

    for w in workers:
        w.cancel()  # Cancel workers

asyncio.run(main())

What happens if I try to get an item from an empty queue?

If you try to get an item from an empty asyncio.Queue, it will wait (block) until an item is available. This is useful for coordinating tasks.