ExecutorService如何处理异常任务

ExecutorService 是 Java 并发包 java.util.concurrent 中的一个接口，它提供了一种将任务提交给线程池执行的方式。当使用 ExecutorService 提交任务时，可能会遇到任务抛出异常的情况。为了处理这些异常任务，可以采用以下方法：

1. 在任务内部捕获异常：

在任务（实现了 Runnable 或 Callable 接口的对象）内部使用 try-catch 语句捕获异常。这样，当任务执行过程中出现异常时，可以在 catch 语句中处理异常，例如记录日志或执行其他恢复操作。

public class MyTask implements Runnable {
    @Override
    public void run() {
        try {
            // 任务逻辑
        } catch (Exception e) {
            // 处理异常
        }
    }
}

2. 使用 Future.get() 方法捕获异常：

当你使用 ExecutorService.submit() 方法提交一个 Callable 任务时，它会返回一个 Future 对象。通过调用 Future.get() 方法，可以获取任务的执行结果。如果任务执行过程中抛出异常，Future.get() 方法会抛出一个 ExecutionException，你可以捕获这个异常并处理它。

ExecutorService executorService = Executors.newFixedThreadPool(1);
Future<Integer> future = executorService.submit(new MyCallableTask());

try {
    Integer result = future.get();
} catch (InterruptedException e) {
    // 处理线程中断异常
} catch (ExecutionException e) {
    // 处理任务执行异常
    Throwable cause = e.getCause();
}
executorService.shutdown();

3. 自定义 ThreadFactory：

可以通过自定义 ThreadFactory 为线程池中的线程设置一个统一的 UncaughtExceptionHandler。这样，当线程执行任务过程中抛出未捕获的异常时，UncaughtExceptionHandler 会被调用，从而处理异常。

public class CustomThreadFactory implements ThreadFactory {
    private final ThreadFactory defaultThreadFactory = Executors.defaultThreadFactory();

    @Override
    public Thread newThread(Runnable r) {
        Thread thread = defaultThreadFactory.newThread(r);
        thread.setUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {
            @Override
            public void uncaughtException(Thread t, Throwable e) {
                // 处理异常
            }
        });
        return thread;
    }
}

// 使用自定义 ThreadFactory 创建 ExecutorService
ExecutorService executorService = Executors.newFixedThreadPool(1, new CustomThreadFactory());

注意：在使用 ExecutorService 时，务必在适当的时候调用 shutdown() 或 shutdownNow() 方法关闭线程池，以避免资源泄漏。