如何在Python中捕获并处理多个并行的Exception异常？-Python教程-PHP中文网

python多线程中异常不会自动冒泡至主线程，需通过concurrent.futures.threadpoolexecutor的future.result()显式获取并捕获；asyncio中gather需设return_exceptions=true才能收集所有协程异常。

如何在python中捕获并处理多个并行的exception异常？

Python 默认的 try...except 只能捕获当前线程中抛出的异常，对多线程或多进程里发生的异常完全无感——你得主动把它们“捞”出来，否则就静默丢失。

多线程中异常不会自动冒泡到主线程

在 threading.Thread 启动的子线程里抛出异常，主线程既不会中断，也不会收到通知。异常信息只打印到 stderr，且无法被 try...except 捕获。

典型现象：程序看似正常退出，但子线程里的 ValueError 或 KeyError 已经发生并消失
根本原因：每个线程有独立的执行栈和异常处理上下文
解决思路：用共享容器（如 queue.Queue 或 threading.local）把异常对象传回主线程

推荐方案：用 concurrent.futures.ThreadPoolExecutor + as_completed

concurrent.futures 是最稳妥的选择，它把异常封装进 Future 对象，主线程调用 result() 时才真正抛出，可统一捕获。

Python Use Agent

智能执行Python任务，自动生成、执行代码并反馈结果，无需额外配置，兼容旧命令。

下载

from concurrent.futures import ThreadPoolExecutor, as_completed
<p>def risky_task(x):
if x == 2:
raise ValueError("bad value")
return x * 2</p><p>with ThreadPoolExecutor(max_workers=3) as executor:
futures = [executor.submit(risky_task, i) for i in [1, 2, 3]]
for future in as_completed(futures):
try:
result = future.result()  # 这里才触发异常
print(result)
except ValueError as e:
print(f"Caught: {e}")
</p>

future.result() 是关键：不调用它，异常就“压着不动”
as_completed() 按完成顺序返回，不是提交顺序
如果用 executor.map()，异常会在迭代时立即抛出，但无法区分是哪个任务出错

asyncio 中多个协程的异常捕获

在 asyncio.gather() 中，默认只要一个协程出错，整个调用就失败；想收集所有异常，得加参数 return_exceptions=True。

import asyncio
<p>async def maybe_fail(n):
if n == 1:
raise RuntimeError("fail fast")
return n ** 2</p><p>async def main():
results = await asyncio.gather(
maybe_fail(0),
maybe_fail(1),
maybe_fail(2),
return_exceptions=True  # 必须加这个
)
for r in results:
if isinstance(r, Exception):
print(f"Exception: {r}")
else:
print(f"OK: {r}")</p><p>asyncio.run(main())
</p>