java 线程池中 submit 提交任务异常可以通过调用 future.get() 捕获，或者为线程池配置 uncaughtexceptionhandler。使用 submit 时，如果任务抛出未捕获的异常，该异常会被封装在 future 对象中，直接调用 get() 会抛出 executionexception；若不调用 get()，异常将静默丢失。对于 execute 方法，异常则直接由线程处理。
如何通过 Future 获取 submit 任务的异常
通过 submit 提交任务后，必须调用返回的 Future 对象的 get() 方法来触发异常的重新抛出。如果在任务执行过程中发生异常，get() 方法会抛出 ExecutionException，其 Cause 是任务实际抛出的异常。开发者需要在代码中显式调用 get() 并处理 InterruptedException 和 ExecutionException，从而获取原始异常信息。
import java.util.concurrent.*;
public class SubmitExample {
public static void main(String[] args) throws Exception {
ExecutorService executor = Executors.newFixedThreadPool(1);
Future<string> future = executor.submit(() -> {
if (true) throw new RuntimeException("Task Failed");
return "Success";
});
try {
String result = future.get(); // 阻塞并检查异常
System.out.println(result);
} catch (ExecutionException e) {
System.out.println("Caught: " + e.getCause().getMessage());
}
executor.shutdown();
}
}</string>
如何配置线程池默认异常处理器
如果不希望每次提交都手动调用 get()，可以为线程池中的工作线程设置 Thread.UncaughtExceptionHandler。当任务抛出未捕获异常时，JVM 会调用该处理器进行处理，如记录日志或发送告警。这种方式适用于后台任务，确保异常不会完全静默丢失，但无法直接获取返回值或统一转换异常类型。
import java.util.concurrent.*;
public class HandlerExample {
public static void main(String[] args) {
ThreadPoolExecutor executor = new ThreadPoolExecutor(
1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue(),
r -> {
Thread t = new Thread(r);
t.setUncaughtExceptionHandler((thread, ex) ->
System.out.println("Unhandled: " + ex.getMessage()));
return t;
});
executor.submit(() -> { throw new RuntimeException("Boom"); });
executor.shutdown();
}
}
submit 提交空 Runnable 任务的行为
当使用 submit 提交一个不抛出异常且无返回值的 Runnable 任务时，Future.get() 将返回 null。如果任务正常完成，get() 不会抛出异常，而是直接返回任务定义的返回值。对于 Callable 任务，若返回值为 null，get() 同样返回 null。这种行为表明 Future 仅用于传递结果或异常，而非控制任务是否执行。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
