在使用 asyncio.TaskGroup 时，如果其中一个任务抛出异常，默认情况下整个 TaskGroup 会取消，但不会自动传播该异常。为了在某个任务异常时整体取消并处理异常，可以结合 try-except 块和 task.cancel() 来实现。以下是一个示例代码，展示如何在某个任务异常时取消所有任务并捕获异常： import asyncio async def task1():

asyncio.TaskGroup 的核心特性是“原子性执行”：任一子任务抛出未处理异常时，它会立即取消所有仍在运行的其他任务，并将该异常重新抛出到上下文外，确保整体操作要么全部成功、要么全部失败；但其取消基于协作式中断（依赖 await 点响应 CancelledError），无法强制终止 CPU 密集型阻塞，也不自带失败任务溯源能力——若需定位异常源头或实现精细化错误处理，必须结合命名任务、异常包装或手动任务状态检查，这使其在可靠性与可控性之间需要开发者主动权衡。

asyncio.TaskGroup 抛异常时是否自动取消其余任务

是的，asyncio.TaskGroup 在任一子任务抛出未处理异常时，会立即取消所有仍在运行的其他任务，并将该异常重新抛出到 with 语句块外。这是它的核心语义，不是可选行为，也不需要额外配置。

为什么 cancel() 不是“尽力而为”，而是强制同步中断

TaskGroup 的取消机制基于 asyncio.CancelledError，它会在当前任务的下一个 await 点被抛出（类似协程的协作式中断）。这意味着：

• 如果某个任务正阻塞在 CPU 密集型计算中（比如 time.sleep() 或纯 Python 循环），它不会被及时取消——必须主动检查 asyncio.current_task().cancelled() 或插入 await asyncio.sleep(0) 让出控制权
• IO 类 awaitable（如 asyncio.sleep()、aiohttp.ClientSession.get()）通常能响应取消；但某些底层库（如未适配 asyncio 的数据库驱动）可能忽略 CancelledError
• 任务退出前仍会执行 finally 块或异步上下文管理器的 __aexit__，可用于清理资源

如何捕获并区分哪个任务先失败

TaskGroup 不提供“谁先挂了”的元信息，异常就是第一个非 CancelledError 的那个。若需定位源头，常见做法是：

• 每个任务用独立的 try/except 包裹，并把原始异常包装成带上下文的新异常，例如 raise RuntimeError("task-a failed") from exc
• 使用 asyncio.create_task(..., name="task-a") 设置名称，再通过 task.get_name() 在异常处理器中记录（注意：仅限 Python 3.8+，且需在 task 启动后读取）
• 避免在多个任务里抛相同类型异常（如都抛 ValueError），否则无法靠类型区分

和 asyncio.gather(return_exceptions=True) 的关键区别

asyncio.gather(..., return_exceptions=True) 会吞掉所有异常，把它们当作普通返回值；而 TaskGroup 是“一损俱损”。实际选择取决于语义需求：

• 要“全部完成，无论成败” → 用 gather(return_exceptions=True)
• 要“原子性执行：全成或全败” → 用 TaskGroup
• 想部分失败后继续执行其余任务？TaskGroup 不支持——得退回到手动管理 create_task + 显式 cancel() + 异常聚合

最易被忽略的一点：TaskGroup 的取消传播是同步的，但任务真正退出可能有延迟；如果你在 with 块结束后立刻检查资源状态，可能看到部分任务还在 pending 或刚进入 cancelled，而非彻底结束。

今天关于《在使用 asyncio.TaskGroup 时，如果其中一个任务抛出异常，默认情况下整个 TaskGroup 会取消，但不会自动传播该异常。为了在某个任务异常时整体取消并处理异常，可以结合 try-except 块和 task.cancel() 来实现。以下是一个示例代码，展示如何在某个任务异常时取消所有任务并捕获异常： import asyncio async def task1(): print("Task 1 started") await asyncio.sleep(1) raise ValueError("Task 1 failed") async def task2(): print("Task 2 started") await asyncio.sleep(2) print("Task 2 completed") async def main(): async with asyncio.TaskGroup() as tg: task1 = tg.create_task(task1()) task2 = tg.create_task(task2()) # 如果任务中出现异常，这里会触发异常 # 但 TaskGroup 不会自动传播异常，需要手动检查 for task in [task1, task2]: if task.done(): if task.exception(): print(f"Caught exception: {task.exception()}") # 可以选择取消其他任务（虽然 TaskGroup 已经取消了） for other_task in [task1, task2]: if other_task != task and not other_task.done(): other_task.cancel() # 运行主函数》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！