asyncio.run()函数是否会使用已存在的event_loop?(生产者消费者的asyncio.Queue)
创始人
2024-09-21 05:30:30
0

asyncio.run() 函数将会创建一个新的 event_loop,而非使用已存在的 event_loop。当然,您可以通过 async with 来手动传递一个 event_loop 来使用现有的 event_loop。

下面是使用 asyncio.Queue 实现生产者消费者模式的示例代码,其中 async with 用于手动传递 event_loop:

import asyncio

async def producer(queue: asyncio.Queue): for i in range(5): await asyncio.sleep(1) await queue.put(i) print(f"Producer puts {i} into queue")

async def consumer(queue: asyncio.Queue): while True: item = await queue.get() await asyncio.sleep(2) print(f"Consumer gets {item} from queue")

async def main(): my_queue = asyncio.Queue() async with asyncio.get_running_loop(): producer_task = asyncio.create_task(producer(my_queue)) consumer_task = asyncio.create_task(consumer(my_queue)) await asyncio.gather(producer_task, consumer_task)

asyncio.run(main())

相关内容

热门资讯

红龙扑克辅助挂!红龙扑克辅助工... WePoker透视辅助版本稳定性对比与推荐‌:红龙扑克辅助挂!红龙扑克辅助工具,(红龙扑克)都是真的...
德扑输赢!德扑保险计算器,德扑... 德扑输赢!德扑保险计算器,德扑机器人一直是有挂(详细ai智能教程);亲,其实确实真的有挂(需添加指定...
aapoker透明挂!wepo... aapoker透明挂!wepoke ai代打辅助(wepoke透明挂)本来有挂(详细透明挂教程);亲...
红龙扑克辅助挂!红龙扑克是正规... 红龙扑克辅助挂!红龙扑克是正规的吗,(红龙扑克)一贯是真的有挂(详细辅助挂教程);是一种具有地方特色...
德州AI智能辅助机器人!德扑输... 德州AI智能辅助机器人!德扑输赢概率计算器,德扑之星开桌一贯有挂(详细ai怎么系统教程);原来确实真...
aapoker透明挂!aapo... aapoker透明挂!aapoker辅助是真的吗,(aa扑克有外挂)竟然真的是有挂(详细有挂教程);...
德扑之星ai代打!德扑之星用刷... 德扑之星ai代打!德扑之星用刷数据吗,德扑之星破解竟然是真的有挂(详细ai智能教程)关于德扑之星ai...
红龙扑克辅助工具!红龙扑克电脑... WePoke高级策略深度解析‌;红龙扑克辅助工具!红龙扑克电脑模拟器,(红龙扑克)果然是真的有挂(详...
德扑之星!德扑牌型胜率,德扑之... 新手教程相关信息汇总(需添加指定薇757446909获取下载链接);德扑之星!德扑牌型胜率,德扑之星...
红龙扑克辅助工具!红龙扑克电脑... 红龙扑克辅助工具!红龙扑克电脑模拟器,(红龙扑克)好像是真的有挂(详细辅助挂教程);(需添加指定薇7...