Python Future 是什么？ThreadPoolExecutor 提交任务后如何获取结果和处理异常？

简化版

Future 表示一个异步执行中的任务结果。用 Executor.submit() 提交任务后会得到 Future，可以用 result() 等待结果、exception() 获取异常、done() 判断是否完成、add_done_callback() 注册完成回调。任务里的异常不会在子线程直接抛到主线程，通常在 future.result() 时重新抛出。

详细版

ThreadPoolExecutor 和 ProcessPoolExecutor 都返回 Future。它把任务状态、结果和异常封装起来，让调用方可以稍后获取。

from concurrent.futures import ThreadPoolExecutor

with ThreadPoolExecutor(max_workers=4) as ex:
    future = ex.submit(fetch, "https://example.com")
    data = future.result(timeout=5)

如果 fetch 抛异常，future.result() 会在调用线程重新抛出该异常。面试回答要强调：提交任务不等于成功完成；必须收集结果或异常，否则后台任务失败可能被忽略。

完整版教学

一、Future 解决什么问题

线程池提交任务后，主线程不能立刻拿到结果，因为任务还在后台执行。Future 就是“未来某个时刻会有结果”的占位对象。它让主线程可以等待、轮询、取消、收集异常。

submit(task) -> Future
                 |
                 +-> running
                 +-> finished with result
                 +-> finished with exception

这比手动创建线程再用共享变量存结果更安全、更统一。

二、result 和 exception 的行为

future.result() 会阻塞直到任务完成，然后返回结果；如果任务抛异常，它会重新抛出异常。future.exception() 返回异常对象，也会等待任务完成。

try:
    value = future.result(timeout=3)
except TimeoutError:
    ...
except Exception as exc:
    ...

timeout 只限制等待时间，不一定取消任务。等待超时后，后台任务可能仍在继续执行。

三、as_completed 和 map 怎么选

executor.map() 按输入顺序返回结果，简单但某个慢任务会卡住对应位置。as_completed() 按完成顺序产出 Future，适合谁先完成先处理。

from concurrent.futures import as_completed

futures = [ex.submit(fetch, url) for url in urls]
for f in as_completed(futures):
    print(f.result())

API	返回顺序	适合
`map`	输入顺序	简单批处理
`as_completed`	完成顺序	及时处理快结果
`submit`	单个 Future	精细控制

四、异常为什么容易被忽略

如果你提交任务后从不调用 result()，任务内部异常不会自动把主线程打崩。它会保存在 Future 里，等待你读取。很多“后台任务悄悄失败”就是因为没人收 Future。

ex.submit(do_work)  # 如果 do_work 抛异常，可能没人发现

更稳的做法是保存 future，统一 result，或者注册回调记录异常。

def log_error(f):
    exc = f.exception()
    if exc:
        logger.exception("task failed", exc_info=exc)

future.add_done_callback(log_error)

线程池不是异常黑洞；真正的问题是你有没有收 Future。

五、cancel 能取消什么

future.cancel() 只能取消尚未开始运行的任务。任务一旦在线程里运行，Python 不能安全强杀这个线程。此时 cancel 通常返回 False。

pending -> cancel 成功
running -> cancel 失败
finished -> cancel 失败

如果需要可中断任务，要在任务函数里设计检查点，例如传入 Event，循环里定期检查是否应该停止。

六、回调在哪个线程执行

add_done_callback 的回调会在 Future 完成时执行，通常由完成任务的线程或管理线程触发。回调应短小，不要在里面做长时间阻塞操作，否则会影响线程池调度。

future.add_done_callback(lambda f: print(f.done()))

如果回调要更新 UI、事件循环或共享状态，要注意线程安全。复杂逻辑更适合把完成事件投递到主线程或队列。

七、常见误区与追问

误区：submit 成功代表任务成功。 只代表任务已提交，结果和异常要看 Future。
误区：线程里的异常会自动在主线程抛出。 不会，通常在 future.result() 时重新抛出。
误区：cancel 能终止正在运行的线程。 不能安全强杀，只能取消未开始任务。
追问：如何按完成顺序处理结果？ 使用 concurrent.futures.as_completed。
追问：map 和 submit 有什么区别？ map 简单批量，submit 返回 Future 便于精细控制。
追问：如何避免任务静默失败？ 保存 Future，调用 result，或 callback 中记录异常。
追问：回调里能做耗时工作吗？ 不建议，回调应短小。

八、加强记忆

Future 记成“后台任务的结果票据”。submit 给你票据，result 取结果并重新抛异常，as_completed 谁先好先处理，cancel 只能取消未运行任务。写线程池代码时，不收 Future 就等于不关心失败，这是最常见的工程坑。

简化版

详细版