Python异步开发中如何优雅停止任务_通过Cancellation机制终止协程

星杰酱_1170

星杰酱_1170

2026-03-27

696人浏览

原创

asyncio.cancel() 不能强制终止协程,仅设取消标志;协程需主动检查cancelled()或在await点响应,否则CPU密集或阻塞操作会继续执行。

python异步开发中如何优雅停止任务_通过cancellation机制终止协程

asyncio.cancel() 能否真正终止正在运行的协程

不能,asyncio.cancel() 只是设置取消标志,协程是否退出取决于它是否主动检查 cancelled() 或在 await 点响应取消。如果协程卡在纯 CPU 计算、阻塞 I/O(如 time.sleep())或没做任何 await,它会继续跑完。

  • 协程必须在可等待对象(如 await asyncio.sleep()、await queue.get())上挂起,才能被中断
  • 长时间同步运算(如循环累加百万次)不会响应取消,需手动插入 await asyncio.sleep(0) 让出控制权
  • 使用 loop.run_in_executor() 执行的阻塞调用,取消只会标记 future,无法杀掉线程中的实际执行

如何在协程内部安全响应取消请求

核心是「尽早检查」和「及时清理」:每次从 await 返回后,先确认自己是否已被取消;资源获取后用 try/finally 或异步上下文管理器确保释放。

  • 在关键 await 前后加 if task.cancelled(): raise asyncio.CancelledError(虽然通常不需显式写,但复杂逻辑中可增强可控性)
  • 打开文件、获取锁、连接数据库等操作后,务必用 async with 或 try/finally 包裹,否则取消可能留下未关闭句柄
  • 避免在 except Exception: 中吞掉 asyncio.CancelledError;它继承自 BaseException,普通 except: 不会捕获它,但 except BaseException: 会——这很危险
async def fetch_with_timeout(url):
    async with aiohttp.ClientSession() as session:
        try:
            async with session.get(url, timeout=5) as resp:
                return await resp.text()
        except asyncio.TimeoutError:
            print("请求超时")
            raise  # 不要静默吞掉,让外层能处理取消或超时

cancel() 后为什么 await task 仍可能抛 CancelledError

因为 task.cancel() 不等于“任务已结束”,只是发起取消请求;真正完成要等你 await task 或调用 task.result() —— 此时若任务因取消而终止,就会抛出 asyncio.CancelledError。

macOS UI 自动化技能包 —— 用 Python 控制你的 Mac
macOS UI 自动化技能包 —— 用 Python 控制你的 Mac

让 macOS 自动化像说话一样简单 —— 用代码控制你的 Mac,无需学习 AppleScript 系统要求 macOS 14+ (Sonoma) Python 3.9+ 需要开启:辅助功能 + 屏幕录制权限

下载
  • 直接 await task 是最常见触发点,别指望 cancel() 后就“万事大吉”
  • 若想忽略取消异常,需显式捕获:try: await task except asyncio.CancelledError: pass
  • 用 asyncio.wait_for(task, timeout=None) 包一层,不能防止 CancelledError,反而可能叠加超时异常,慎用
  • 批量取消多个 task 时,建议用 asyncio.gather(*tasks, return_exceptions=True),避免一个失败中断全部

信号处理(如 Ctrl+C)下如何统一触发所有任务取消

主线程收到 SIGINT(Ctrl+C)时,默认会中断 run_forever(),但已调度的 task 不会自动取消——得自己监听并手动 cancel。

  • 用 loop.add_signal_handler(signal.SIGINT, lambda: asyncio.create_task(shutdown())) 注册清理逻辑
  • shutdown() 函数里应遍历 asyncio.all_tasks(),对非当前 task 调用 task.cancel(),然后 await asyncio.gather(*tasks, return_exceptions=True)
  • 注意:Python 3.9+ 的 asyncio.Runner 提供了更简洁的 run() + close() 模式,但底层仍依赖同套取消逻辑
  • 测试时别只按 Ctrl+C 看是否退出,要验证文件是否关闭、连接是否释放、日志是否写入完成

取消不是“杀死进程”,而是协作式中断。最容易被忽略的是:协程里那些看似无害的同步循环、没加 await 的重试逻辑、以及忘记在 finally 块里 close() 的异步资源——它们会让 cancel() 形同虚设。

Python免费学习笔记(深入):立即使用
在学习笔记中,你将探索 Python 的核心概念和高级技巧!

相关专题

更多
python打包成可执行文件
python打包成可执行文件

本专题为大家带来python打包成可执行文件相关的文章,大家可以免费的下载体验。

2023.07.20

1831

4

python能做什么
python能做什么

python能做的有:可用于开发基于控制台的应用程序、多媒体部分开发、用于开发基于Web的应用程序、使用python处理数据、系统编程等等。本专题为大家提供python相关的各种文章、以及下载和课程。

2023.07.25

4884

7

format在python中的用法
format在python中的用法

Python中的format是一种字符串格式化方法,用于将变量或值插入到字符串中的占位符位置。通过format方法,我们可以动态地构建字符串,使其包含不同值。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

2023.07.31

1789

3

python教程
python教程

Python已成为一门网红语言,即使是在非编程开发者当中,也掀起了一股学习的热潮。本专题为大家带来python教程的相关文章,大家可以免费体验学习。

2023.08.03

29237

23

python环境变量的配置
python环境变量的配置

Python是一种流行的编程语言,被广泛用于软件开发、数据分析和科学计算等领域。在安装Python之后,我们需要配置环境变量,以便在任何位置都能够访问Python的可执行文件。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.04

3487

5

python eval
python eval

eval函数是Python中一个非常强大的函数,它可以将字符串作为Python代码进行执行,实现动态编程的效果。然而,由于其潜在的安全风险和性能问题,需要谨慎使用。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.04

3507

5

scratch和python区别
scratch和python区别

scratch和python的区别:1、scratch是一种专为初学者设计的图形化编程语言,python是一种文本编程语言;2、scratch使用的是基于积木的编程语法,python采用更加传统的文本编程语法等等。本专题为大家提供scratch和python相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.11

1223

5

python合并两个列表
python合并两个列表

Python是一种强大的编程语言,具有许多方便的功能和工具。在Python中,有多种方法可以合并两个列表。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.08.10

616

4

python是前端还是后端
python是前端还是后端

Python属于前端也属于后端,其灵活性和丰富的生态系统使得开发人员能够在不同的领域中灵活运用。本专题为大家提供python相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.11

2723

5

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Uvicorn官方安装与入门手册
Uvicorn官方安装与入门手册

共0课时 | 0人学习

Python uv官方项目管理指南
Python uv官方项目管理指南

共0课时 | 0人学习

Python uv官方安装与入门文档
Python uv官方安装与入门文档

共0课时 | 0人学习