asyncio.gather() 是 Python 异步编程里非常常见的并发工具，但它有一个很容易踩坑的点：异常处理行为并不直观。很多人以为某个协程报错后一定会立刻抛出异常，但实际上可能出现：

异常被“吞掉”

其他任务继续运行

某些异常永远没人处理

日志里出现 Task exception was never retrieved

下面把几个核心问题拆开讲。

asyncio.gather() 的默认行为

先看最常见写法：

import asyncio

async def ok():

await asyncio.sleep(1)

return "success"

async def fail():

await asyncio.sleep(0.5)

raise ValueError("something wrong")

async def main():

result = await asyncio.gather(

ok(),

fail()

)

print(result)

asyncio.run(main())

运行结果：

ValueError: something wrong

这里看起来没问题。

但真正的问题在于：

gather() 只会抛出第一个异常。

其它协程怎么办？

很多人以为：

一个任务报错 → gather 全部停止

实际上不是。

例如：

import asyncio

async def task1():

await asyncio.sleep(1)

raise ValueError("task1 error")

async def task2():

await asyncio.sleep(2)

raise RuntimeError("task2 error")

async def main():

try:

await asyncio.gather(

task1(),

task2()

)

except Exception as e:

print("捕获:", e)

asyncio.run(main())

输出：

捕获: task1 error

你会发现：

task2 的异常没有出现

但它实际上仍可能在后台继续运行

这就是“异常吞噬感”。

为什么会这样？

因为：

gather()

默认逻辑是：

等待所有任务

一旦有第一个异常

立即把异常抛给调用者

其它任务可能还在执行

而调用方：

except Exception:

已经提前退出。

于是：

后面的异常没人接

某些任务被取消

某些任务继续运行

某些异常变成未处理异常

最危险的问题：异常丢失

看这个：

import asyncio

async def bad():

await asyncio.sleep(1)

raise Exception("boom")

async def main():

asyncio.gather(bad())

await asyncio.sleep(2)

asyncio.run(main())

输出：

Task exception was never retrieved

原因：

你创建了 gather()：

asyncio.gather(bad())

但没有：

await

所以：

gather 返回的 Future 没人等待

内部异常没人取出

asyncio 认为异常泄漏

这是 asyncio 最经典坑之一。

return_exceptions=True

很多人会这样：

results = await asyncio.gather(

task1(),

task2(),

return_exceptions=True

)

这时：

异常不会抛出。

而是：

[

ValueError(...),

RuntimeError(...)

]

例如：

import asyncio

async def ok():

return 123

async def fail():

raise ValueError("bad")

async def main():

results = await asyncio.gather(

ok(),

fail(),

return_exceptions=True

)

print(results)

asyncio.run(main())

输出：

[123, ValueError('bad')]

这里隐藏的新坑

很多人以为：

return_exceptions=True

是“安全模式”。

其实不是。

因为：

异常对象会被当成正常返回值。

于是：

for r in results:

print(r + 1)

直接炸：

TypeError

因为：

r

可能是异常对象。

正确写法：

for r in results:

if isinstance(r, Exception):

print("异常:", r)

else:

print("结果:", r)

gather 与 cancel 的微妙行为

更复杂的问题：

gather.cancel()

不一定真正停止所有任务。

例如：

import asyncio

async def worker():

try:

while True:

print("running")

await asyncio.sleep(1)

finally:

print("cleanup")

async def main():

g = asyncio.gather(worker())

await asyncio.sleep(2)

g.cancel()

try:

await g

except asyncio.CancelledError:

print("cancelled")

asyncio.run(main())

这里：

gather 被取消

内部 task 收到取消信号

task 是否真正停止，取决于它是否响应取消

如果协程内部：

长时间 CPU 运算

没有 await

吞掉 CancelledError

那任务可能根本停不下来。

python asyncio.gather 中异常吞噬的问题