在多线程编程里，线程异常的处理和普通单线程程序有很大不同。由于每个线程拥有独立的执行栈，子线程中未捕获的异常通常不会影响其他线程，也不会直接中断主线程，这就使得问题容易被忽略。如果处理不当，轻则任务失败无感知，重则导致数据不一致或资源无法释放。
为什么线程异常难以发现
当我们直接继承Thread或实现Runnable时，run方法内部抛出的异常如果没有被捕获，会交由线程的未捕获异常处理器处理，默认只是打印堆栈。主线程无法通过常规的try catch拿到这个异常，因为异常发生在另一个调用栈中。
常见误区
- 只在主线程包try catch，以为能捕获子线程异常
- 使用线程池却不关心任务执行结果
- 忽略线程池配置中的异常钩子
使用未捕获异常处理器
可以为线程或线程组设置UncaughtExceptionHandler，统一记录或上报异常。下面以Java为例：
public class MyHandler implements Thread.UncaughtExceptionHandler {
@Override
public void uncaughtException(Thread t, Throwable e) {
// 记录线程名称和异常信息
System.err.println("线程 " + t.getName() + " 发生异常: " + e.getMessage());
}
}
public class Demo {
public static void main(String[] args) {
Thread thread = new Thread(() -> {
throw new RuntimeException("子线程出错");
});
thread.setUncaughtExceptionHandler(new MyHandler());
thread.start();
}
}
通过Future获取异常
使用线程池提交Callable任务时，可以通过Future的get方法拿到执行结果或异常，这是最推荐的做法之一。
import java.util.concurrent.*;
public class FutureDemo {
public static void main(String[] args) {
ExecutorService pool = Executors.newSingleThreadExecutor();
Future<String> future = pool.submit(() -> {
if (true) {
throw new RuntimeException("计算失败");
}
return "ok";
});
try {
String result = future.get();
System.out.println(result);
} catch (InterruptedException | ExecutionException e) {
// ExecutionException中包含了子线程的真实异常
System.err.println("任务异常: " + e.getCause());
} finally {
pool.shutdown();
}
}
}
线程池中的afterExecute钩子
自定义ThreadPoolExecutor并重写afterExecute方法，可以在任务结束后统一处理异常，而不必每个任务单独写捕获逻辑。
import java.util.concurrent.*;
public class CustomPool extends ThreadPoolExecutor {
public CustomPool() {
super(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>());
}
@Override
protected void afterExecute(Runnable r, Throwable t) {
super.afterExecute(r, t);
if (t != null) {
System.err.println("afterExecute捕获异常: " + t.getMessage());
}
// 如果任务是Future，异常可能被包装在Future内部
if (r instanceof Future<?>) {
try {
((Future<?>) r).get();
} catch (Exception e) {
System.err.println("Future异常: " + e.getCause());
}
}
}
}
任务内部统一捕获
在Runnable或Callable的最外层包一层try catch，将异常转为返回值或回调，适合需要明确业务错误码的场景。
import threading
def safe_task(callback):
try:
# 模拟业务处理
raise ValueError("处理失败")
except Exception as e:
callback(str(e))
def on_error(msg):
print("任务错误: " + msg)
t = threading.Thread(target=safe_task, args=(on_error,))
t.start()
t.join()
小结
处理线程异常的核心在于明确异常边界：要么在任务内消化并上报，要么通过Future或异常处理器把异常暴露出来。合理使用上述方式，可以显著提升多线程程序的稳定性和可观测性。