taskgroup抛出的是exceptiongroup而非单个异常,必须用except*语法捕获;它聚合多任务异常、不返回混合结果、自动取消其余任务但需协程响应取消。

TaskGroup抛出的异常根本捕不到?一定是没用except*
写except ValueError:却进不去分支,不是代码逻辑错,而是TaskGroup根本不抛ValueError——它抛的是ExceptionGroup,一个包裹了所有子异常的容器。老式except语法对它完全无效。
必须改用Python 3.11新增的except*语法:
-
except* ValueError as eg:——eg.exceptions是匹配到的所有ValueError实例列表 -
except* (httpx.HTTPStatusError, asyncio.TimeoutError):—— 可同时匹配多种类型 -
except* BaseException:兜底,但会捕获KeyboardInterrupt等信号,慎用
漏掉*,异常就静默吞掉或向上冒泡成未处理错误,资源清理逻辑(比如async with httpx.AsyncClient()的关闭)可能根本没执行。
多个任务同时失败,只看到第一个堆栈?那是ExceptionGroup没展开
TaskGroup在多个子任务**同一时刻**抛出不同异常时(比如DNS解析失败 + TLS握手超时),才会聚合为ExceptionGroup并一次性抛出。你不能靠str(eg)看全貌,得手动遍历:
except* ValueError as eg:
for exc in eg.exceptions:
print(f"子任务异常: {type(exc).__name__}: {exc}")
常见错误现象:print(eg)只输出摘要,看不到每个异常的完整traceback;想用isinstance(exc, ValueError)判断eg本身,结果恒为False——因为eg是ExceptionGroup实例,不是ValueError。
为什么gather里加return_exceptions=True后还得遍历结果?TaskGroup省掉这步
asyncio.gather(coro1(), coro2(), return_exceptions=True)返回的是混合列表:[result1, ValueError, result3]。你得逐个检查类型,再分发处理,容易漏判或误判。
TaskGroup不返回结果列表,也不塞异常进返回值——它只管生命周期和异常聚合。你要自己存Task引用,最后调.result()拿值:
- 正常完成的任务,
task.result()返回值 - 失败的任务,
task.result()会再次抛出原始异常(已包含在ExceptionGroup中) - 无需手动区分“是结果还是异常”,异常统一由
except*拦截
这省掉了isinstance(x, Exception)这种脆弱判断,也避免了因类型检查疏漏导致的脏数据写入。
TaskGroup退出时自动取消其余任务,但你的协程得能响应取消
TaskGroup在首个异常发生时,会向其他正在运行的任务发送CancelledError。但这不是强制杀死——协程必须在可中断点(如await)响应取消,否则会卡住直到超时或手动干预。
确保你的协程具备协作式取消能力:
- 避免在
while True:循环里死等,加await asyncio.sleep(0)让出控制权 - 使用
async with管理资源(如HTTP客户端、数据库连接),它们的__aexit__会在取消时触发清理 - 不要在
try/except里吞掉CancelledError,除非你明确要忽略取消信号
如果某个子任务没响应取消,TaskGroup的async with块就会卡住等待它结束,整个并发流程被拖慢——这比gather更隐蔽,因为表面看只是“慢”,而不是“报错”。
Python免费学习笔记(深入):立即使用
在学习笔记中,你将探索 Python 的核心概念和高级技巧!











