concurrent.futures线程异常无提示：如何捕获线程内抛出的异常？

问题原因 #

使用concurrent.futures.ThreadPoolExecutor时，线程任务中抛出的异常会被Future对象捕获并存储，只有当你主动调用Future的result()或exception()方法时，异常才会被触发并显示。你当前的代码仅遍历已完成的任务，没有访问任务的结果或异常，导致异常被隐藏，程序看似无提示退出。

解决方法 #

在遍历as_completed返回的Future对象时，必须主动获取任务的结果或异常，才能让线程内的异常暴露出来。以下是几种实现方式：

方式1：直接获取结果（异常会直接抛出到主线程）

修改遍历逻辑，对每个已完成的Future调用result()方法：

with concurrent.futures.ThreadPoolExecutor() as executor:
    futureHost.update({executor.submit(infoCatalina, host): host for host in onlineHosts})
    futureHost.update({executor.submit(infoVersion, host): host for host in onlineHosts})
    futureHost.update({executor.submit(infoMount, host): host for host in onlineHosts})
    
    for future in concurrent.futures.as_completed(futureHost):
        x = progress(x, progBarLength)
        # 调用result()，任务中的异常会在这里抛出
        future.result()

方式2：捕获并处理异常

如果需要自定义异常提示，用try-except包裹result()调用：

with concurrent.futures.ThreadPoolExecutor() as executor:
    futureHost.update({executor.submit(infoCatalina, host): host for host in onlineHosts})
    futureHost.update({executor.submit(infoVersion, host): host for host in onlineHosts})
    futureHost.update({executor.submit(infoMount, host): host for host in onlineHosts})
    
    for future in concurrent.futures.as_completed(futureHost):
        x = progress(x, progBarLength)
        try:
            result = future.result()
        except ZeroDivisionError as e:
            print(f"[{futureHost[future]}] 执行infoVersion出错: 除零错误 - {e}")
        except Exception as e:
            print(f"[{futureHost[future]}] 任务执行出错: {type(e).__name__} - {e}")

方式3：主动获取异常对象

用exception()方法直接获取任务中的异常，避免触发异常抛出：

with concurrent.futures.ThreadPoolExecutor() as executor:
    futureHost.update({executor.submit(infoCatalina, host): host for host in onlineHosts})
    futureHost.update({executor.submit(infoVersion, host): host for host in onlineHosts})
    futureHost.update({executor.submit(infoMount, host): host for host in onlineHosts})
    
    for future in concurrent.futures.as_completed(futureHost):
        x = progress(x, progBarLength)
        exc = future.exception()
        if exc is not None:
            print(f"[{futureHost[future]}] 任务异常: {type(exc).__name__}: {exc}")

内容的提问来源于stack exchange，提问作者shepster