ExecutorService怎么处理异常

在 Java 中，ExecutorService 本身不会自动把任务中的异常抛出到主线程，如果处理不当，异常很容易被“吞掉”。下面按使用方式系统说明如何处理异常。

一、不同提交方式下的异常处理

1. execute(Runnable)

executor.execute(() -> {
    throw new RuntimeException("error");
});

✅ 异常会：

• 被线程的 未捕获异常处理器（UncaughtExceptionHandler） 捕获
• 不会抛给调用者

处理方式

Thread.setDefaultUncaughtExceptionHandler((t, e) -> {
    System.err.println("Thread " + t.getName() + " error: " + e);
});

或自定义 ThreadFactory：

ThreadFactory factory = r -> {
    Thread t = new Thread(r);
    t.setUncaughtExceptionHandler((t1, e) -> System.err.println(e));
    return t;
};

2. submit(Runnable) / submit(Callable)

Future<?> future = executor.submit(() -> {
    throw new RuntimeException("error");
});

❌ 异常不会立即抛出 ✅ 异常被封装在 Future 中

正确处理方式

try {
    future.get(); // 会抛出 ExecutionException
} catch (ExecutionException e) {
    Throwable cause = e.getCause(); // 真正的异常
    e.printStackTrace();
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
}

⚠️ 如果不调用 get()，异常会被吞掉。

二、推荐做法（生产级）

✅ 方式 1：使用 Callable + Future

最清晰、可控

Future<String> f = executor.submit(() -> {
    if (true) throw new RuntimeException("fail");
    return "ok";
});

try {
    f.get();
} catch (ExecutionException e) {
    log.error("task failed", e.getCause());
}

✅ 方式 2：在任务内部 try-catch（业务异常）

executor.execute(() -> {
    try {
        business();
    } catch (Exception e) {
        log.error("task error", e);
    }
});

适合：

• 不希望中断线程
• 异常可恢复或记录即可

✅ 方式 3：自定义 ThreadPoolExecutor 重写 afterExecute

new ThreadPoolExecutor(...) {
    @Override
    protected void afterExecute(Runnable r, Throwable t) {
        if (t != null) {
            log.error("task error", t);
        }
        if (r instanceof Future<?>) {
            try {
                ((Future<?>) r).get();
            } catch (ExecutionException e) {
                log.error("future error", e.getCause());
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }
    }
};

✅ 统一捕获 execute 和 submit 的异常

三、Spring 环境（@Async）

@Async
public void run() {
    throw new RuntimeException("error");
}

✅ 使用：

@Bean
public AsyncUncaughtExceptionHandler asyncUncaughtExceptionHandler() {
    return (ex, method, params) -> log.error("async error", ex);
}

四、总结对照表

如果你有具体场景（比如：定时任务 / 批量任务 / 线程池参数），我可以给你一个可直接用的模板代码。