如何在Python3.5中使用queue创建多工作者协程

import asyncio
import queue

async def worker(queue):
    while True:
        item = await queue.get()
        # 处理任务
        print("Processing item:", item)
        await asyncio.sleep(1)  # 模拟任务处理时间
        queue.task_done()

async def main():
    # 创建一个队列
    q = queue.Queue()

    # 创建多个工作者协程
    num_workers = 3
    workers = []
    for _ in range(num_workers):
        worker_coro = worker(q)
        workers.append(worker_coro)

    # 启动工作者协程
    await asyncio.gather(*workers)

# 创建事件循环并运行主协程
loop = asyncio.get_event_loop()
loop.run_until_complete(main())

# 将任务添加到队列中
for i in range(10):
    q.put(i)

# 等待所有任务完成
await q.join()