task.cancel() 不立即终止协程,仅设状态为cancelled并抛出cancellederror,该异常只在下次await点触发;若协程卡在纯计算、阻塞i/o或无await循环中,则取消不生效。

Task.cancel() 为什么有时不生效
Task.cancel() 并不是“发个信号就立刻终止协程”,它只是把任务的 _state 设为 CANCELLED,并抛出 CancelledError —— 但这个异常**只会在下一次 await 点被检测并抛出**。如果协程正卡在纯计算、阻塞 I/O(如 time.sleep()、requests.get())、或没做任何 await 的循环里,CancelledError 就永远没机会冒出来。
常见错误现象:task.cancel() 返回 True,但任务仍在后台跑着;日志没看到 CancelledError;asyncio.run() 卡住不退出。
- 纯 CPU 循环(如
while True: x += 1)不会响应 cancel,必须主动插入await asyncio.sleep(0)让出控制权 - 同步阻塞调用(如
time.sleep(10)、subprocess.run(...))会彻底阻塞事件循环,cancel 完全失效 - 未加
try/except CancelledError的协程,异常会向上冒泡;但若被外层except Exception:吞掉,就看似“取消失败”
如何让 cancel 真正落地:三类关键配合
要让 Task.cancel() 生效,必须满足“可取消点 + 可中断操作 + 显式处理”三个条件。
-
插入可取消点:在长循环中定期
await asyncio.sleep(0)或await asyncio.yield_()(Python 3.12+),否则事件循环无法调度 cancel 检查 -
替换阻塞调用:把
time.sleep(5)换成await asyncio.sleep(5);把requests.get()换成aiohttp.ClientSession().get();否则 cancel 对线程内阻塞无能为力 -
显式捕获与清理:在协程末尾用
try/finally做资源释放,或用except asyncio.CancelledError:捕获后手动 close socket / cancel sub-tasks / 写回临时状态
示例:一个易被 cancel 的轮询协程
async def polling_task():
while True:
try:
await asyncio.sleep(1) # ← 可取消点
data = await fetch_data() # ← 非阻塞请求
process(data)
except asyncio.CancelledError:
print("cleaning up...")
await cleanup_resources()
raise # 必须 re-raise,否则 cancel 被静默吞掉
cancel 后 task.done() 为 False?检查是否 await 了 task
调用 task.cancel() 后,task.done() 仍返回 False 是正常现象 —— 因为任务尚未真正结束,只是被标记为“待取消”。真正完成需等待 CancelledError 抛出并传播完毕。
- 如果你直接调用
task.cancel()就以为任务已死,然后立即del task或忽略它,那它可能还在后台运行 - 正确做法是
await task或await asyncio.wait_for(task, timeout=...),让协程有机会执行完 finally 或被捕获 - 若想非阻塞等待取消完成,可用
asyncio.create_task(task)后再await asyncio.shield(task)配合超时逻辑,但本质仍是等它自己结束
注意:task.cancelled() 返回 True 表示“已被调用 cancel”,不代表“已结束”;task.done() 才表示“已终止(无论成功/异常/cancel)”。
子任务、线程、进程中的 cancel 传递限制
Task.cancel() 的作用域仅限于当前事件循环中的协程任务,对以下场景完全无效:
- 通过
loop.run_in_executor()提交的线程任务:cancel 不会中断线程,只能等它自己结束;需额外设计线程安全的中断标志(如threading.Event) - 子进程(
subprocess.Popen):cancel 不会杀进程,必须在except CancelledError中显式调用proc.terminate()或proc.kill() - 嵌套的
asyncio.create_task():父 task cancel 不会自动 cancel 子 task,必须手动遍历asyncio.all_tasks()或保存子 task 引用后逐个 cancel
容易被忽略的一点:即使你在主协程里 await subtask,一旦 subtask 已经进入不可取消的阻塞段(比如正在做 CPU 密集计算),父协程 cancel 也无法穿透进去 —— 协程取消不是操作系统级的抢占式中断,它依赖协作式调度。
Python免费学习笔记(深入):立即使用
在学习笔记中,你将探索 Python 的核心概念和高级技巧!











