如何终止已await的长时asyncio Task？cancel()失效问题求助

数据老陈

2026-7-5

解决asyncio后台Task无法终止的问题

你的核心问题是代码里的await task让main协程被无限阻塞，导致后续的task.cancel()根本没机会执行——因为background_task是无限循环，await task会一直等待它结束，永远到不了取消的代码行。

修正方案1：强制取消后台任务

调整main的逻辑，先让后台任务运行一段时间，再执行取消操作，同时处理取消后的异常：

import asyncio

async def background_task():
    while True:
        print('doing something')
        await asyncio.sleep(1)

async def main():
    task = asyncio.create_task(background_task())
    # 让后台任务运行3秒
    await asyncio.sleep(3)
    # 触发任务取消
    task.cancel()
    try:
        # 等待任务处理取消操作，避免未处理任务的警告
        await task
    except asyncio.CancelledError:
        print('后台任务已被取消')
    print('Done!')

asyncio.run(main())

运行这段代码，后台任务会打印3次"doing something"，然后被取消，最终输出"Done!"。

修正方案2：用事件通知任务主动退出

如果不想用强制取消的方式，可以通过asyncio.Event给后台任务传递停止信号，让任务自行退出循环，这种方式更优雅可控：

import asyncio

async def background_task(stop_event):
    # 循环判断停止事件是否触发
    while not stop_event.is_set():
        print('doing something')
        await asyncio.sleep(1)

async def main():
    stop_event = asyncio.Event()
    task = asyncio.create_task(background_task(stop_event))
    await asyncio.sleep(3)
    # 设置停止事件，通知后台任务退出
    stop_event.set()
    # 等待任务正常结束
    await task
    print('Done!')

asyncio.run(main())