Python异步任务取消需协程主动配合：调用Task.cancel()仅发取消请求，协程须在可取消挂起点响应CancelledError或定期检查cancelled()；长循环应插入await asyncio.sleep(0)或显式判断；timeout控制取消边界，shield保护关键清理；CancelledError不可被Exception捕获，需显式处理以确保资源释放。
Python中异步任务的取消，核心在于协程的可取消性与取消信号的传递机制。asyncio.Task支持主动取消，但协程本身需配合检查取消状态或响应中断，否则可能无法真正终止执行。
Task.cancel() 是触发取消的起点，不是立即终止
调用 task.cancel() 仅向任务发送取消请求，并将任务状态设为“已取消”（cancelled），但实际协程是否停止，取决于它是否在等待可取消的挂起点（如 await asyncio.sleep()、await queue.get() 等）。
- 若协程正在执行纯CPU计算或阻塞IO（如 time.sleep()、requests.get()），cancel() 不会中断它，任务会继续运行直到下一次 await
- 若协程在 await 一个支持取消的 awaitable 上（如 asyncio.sleep、asyncio.wait_for、aiohttp.ClientSession.get），该 awaitable 通常会在收到取消时抛出 CancelledError
- 必须在协程内部合理处理 CancelledError（通常不捕获，让其向上冒泡），才能确保资源清理和协程退出
协程内主动检查取消状态
对于长循环或计算密集型逻辑，不能只依赖 await 挂起点自动响应取消，应定期手动检查 asyncio.current_task().cancelled() 或使用 asyncio.sleep(0) 插入可取消的让点。
python-script-generator
下载
快速生成专业的 Python 脚本和应用代码。一键创建完整项目结构，支持CLI、API、爬虫、Bot、Django等多种项目类型，包含完整的项目结构、配置文件、依赖管理、测试、README和文档。
- 推荐方式：在 while 循环中插入 await asyncio.sleep(0)，它不延迟但允许事件循环检查取消信号
- 也可显式判断：if asyncio.current_task().cancelled(): break，并在退出前执行清理
- 避免在循环中做长时间同步运算而不让出控制权，否则 cancel() 将“失灵”
使用 timeout 或 shield 控制取消边界
在组合多个协程时，需明确哪些部分允许被取消、哪些必须完成：
立即学习“Python免费学习笔记（深入）”；
- asyncio.wait_for(coro, timeout)：超时后自动取消 coro，适合有明确时限的任务
- asyncio.shield(coro)：保护协程不被外部取消影响，常用于关键清理逻辑（如关闭连接、写日志）
- 组合示例：await asyncio.shield(close_db_connection()) 可确保即使主任务被取消，数据库连接仍能安全关闭
异常传播与资源清理的最佳实践
CancelledError 是 BaseException 的子类，不会被普通 except Exception: 捕获，这是设计使然——强制开发者意识到取消是控制流中断，而非普通错误。
- 不要静默吞掉 CancelledError；若需拦截，应 except CancelledError: 后重新 raise，或在 finally 块中完成清理
- 所有异步上下文管理器（async with）和异步迭代器（async for）都应在退出时响应取消并释放资源
- 自定义异步类中，__aexit__ 方法必须能处理 CancelledError，避免资源泄漏
