threadpoolexecutor.submit() 不立即抛异常，异常被封装在future中，需调用result()或exception()显式检查；map()异常延迟至迭代时触发，且不支持timeout；多任务需遍历future列表分别处理结果与异常。
concurrent.futures.ThreadPoolExecutor.submit() 不会立即抛出异常
调用 submit() 后，异常不会在主线程中立即出现，而是被封装进 Future 对象里。如果你不显式检查或获取结果，异常会被静默吞掉——这是最常被忽略的点。
正确做法是主动调用 future.result()（它会重新抛出子线程里的异常），或用 future.exception() 检查是否出错：
from concurrent.futures import ThreadPoolExecutor
import time
<p>def risky_task(x):
if x == 2:
raise ValueError("boom on input 2")
return x * x</p><p>with ThreadPoolExecutor() as executor:
futures = [executor.submit(risky_task, i) for i in [1, 2, 3]]</p><pre class="brush:python;toolbar:false;">for f in futures:
try:
print(f.result()) # ← 关键：这里才真正触发异常
except ValueError as e:
print(f"Caught: {e}")
map() 方式下异常延迟到迭代时才暴露
executor.map() 返回的是一个惰性迭代器，异常不会在提交时或 map() 调用时抛出，而是在你遍历结果时才逐个触发——这点和 submit() + result() 类似，但更隐蔽。
- 如果你用
list(executor.map(...))包一层，异常会在构造 list 时集中爆发 - 如果用 for 循环逐个取值，异常只影响当前迭代项，后续仍可继续
-
map()不支持timeout参数，无法控制单个任务超时
示例：
try:
results = list(executor.map(risky_task, [1, 2, 3]))
except ValueError as e:
print("Map failed at first error:", e) # ← 仅捕获第一个异常，后续不执行
多个子线程异常如何全部收集？
concurrent.futures 默认“失败即停”，但实际中你可能需要知道所有任务的成败情况。这时不能依赖 map() 或裸 result()，得手动遍历 Future 列表并分别处理：
- 用
future.exception()判断是否出错（返回Exception实例或None） - 用
future.result()获取成功结果，但仅在确定没异常后调用，避免重复抛异常 - 注意：
exception()和result()都是线程安全的，可随时调用
推荐模式：
results = []
errors = []
for f in futures:
if f.exception() is not None:
errors.append(f.exception())
else:
results.append(f.result())
asyncio 环境下别混用 concurrent.futures 的 Future
如果你在 async def 函数里用 loop.run_in_executor()，返回的是 asyncio.Future，不是 concurrent.futures.Future。它们的 result()、exception() 行为一致，但类型不同，不能直接丢给 as_completed() 或 wait()（那些只认 concurrent.futures 的 Future）。
常见错误：
- 对
asyncio.Future调用concurrent.futures.as_completed()→ 报TypeError: 'Future' object is not iterable - 误以为
await future等价于future.result()—— 实际上await也会传播异常，但上下文是协程，堆栈更浅
纯线程池场景就老实用 ThreadPoolExecutor；要混用 asyncio，请统一用 asyncio.to_thread()（Python 3.9+）或明确区分 Future 类型。
异常捕获这件事，本质不是“怎么写”，而是“在哪一刻让异常浮出水面”。submit() 只打包，result() 才拆包——漏掉后者，等于白做并发。
Python免费学习笔记（深入）：立即使用
在学习笔记中，你将探索 Python 的核心概念和高级技巧！
