为何asyncio create_task创建的任务无法永久运行?求助
问题分析与解决方案
我懂你的困扰啦——你本来想让while_loop永久运行,但现在它跟着some_func执行完毕就停了,这是因为你用的loop.run_until_complete(some_func())核心逻辑是让事件循环只等待some_func这个协程完成,一旦它执行结束,事件循环就会被终止,之前创建的while_loop任务自然会被强制取消,所以就不再打印数字了。
解决办法
我们需要让事件循环持续运行,或者确保while_loop任务能在some_func完成后继续执行。这里有两种简单的实现方式:
方式一:使用asyncio.run(Python 3.7+ 推荐写法)
用asyncio.run启动主协程,在主协程里同时管理两个任务:
import asyncio async def while_loop(): n = 0 while True: print(f"{n}") await asyncio.sleep(2) n = n + 1 async def some_func(): await asyncio.sleep(5) print("Some Func") async def main(): # 将while_loop创建为后台任务 loop_task = asyncio.create_task(while_loop()) # 等待some_func完成 await some_func() # 让主协程一直等待while_loop(因为它是无限循环,程序会持续运行) await loop_task asyncio.run(main())
方式二:用loop.run_forever让事件循环永久运行
如果你习惯旧版事件循环API,可以直接让事件循环一直运行,同时把两个任务都加入循环:
import asyncio loop = asyncio.get_event_loop() async def while_loop(): n = 0 while True: print(f"{n}") await asyncio.sleep(2) n = n + 1 async def some_func(): await asyncio.sleep(5) print("Some Func") # 把两个协程都创建为任务加入事件循环 loop.create_task(while_loop()) loop.create_task(some_func()) # 启动事件循环并让它持续运行 loop.run_forever()
这两种方式都能实现你想要的效果:some_func在5秒后打印"Some Func",之后while_loop会继续打印3、4、5……一直持续下去。
内容的提问来源于stack exchange,提问作者slaw
相关产品推荐
相关产品推荐

