达到指定条件时如何正确取消asyncio无限循环任务

原有实现的问题 #

你当前使用loop.stop()直接终止事件循环的写法比较粗暴，属于直接操作底层事件循环接口，不符合asyncio高层API的设计规范，容易导致未完成的任务无法正常清理，出现资源泄漏问题，部分场景下还可能导致asyncio.run()抛出运行异常。

推荐规范实现 #

对于单任务串行运行的场景，最简洁安全的方式是让子任务返回终止信号，外层循环接收到信号后主动跳出，遵循asyncio的生命周期管理规则，示例代码如下：

import asyncio

async def main(numb):
    if numb == 20:
        print('Reached')
        # 返回终止标识通知外层停止
        return True
    print(numb)
    return False

async def create_tasks():
    numb = 0 
    while True:
        task = asyncio.create_task(main(numb))
        stop_flag = await task
        if stop_flag:
            # 主动跳出无限循环，函数正常返回
            break
        numb += 1

asyncio.run(create_tasks())
print("脚本执行完成")

常见问题说明 #

你提到的「直接使用return语句会导致事件循环挂起」是因为return仅退出了main函数本身，外层create_tasks中的while True无限循环没有收到终止信号，会持续创建新的任务运行，所以事件循环永远不会自动结束。
如果是多任务并行的场景，可以通过asyncio.Future对象作为全局终止信号，所有任务监控future的状态，收到终止信号后主动退出即可。

内容的提问来源于stack exchange，提问作者Jonas