Python中的异步队列及其实现方法

import asyncio

async def producer(queue):
    for i in range(10):
        await queue.put(f"pidancode.com-{i}")
        await asyncio.sleep(1)

async def consumer(queue):
    while True:
        data = await queue.get()
        print(data)
        await asyncio.sleep(0.5)
        queue.task_done()

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

asyncio.run(main())