Java ExecutorService如何处理异常和错误

在Java中，当使用ExecutorService执行任务时，异常和错误处理是非常重要的。如果在提交给ExecutorService的任务中发生异常，那么这个异常需要被捕获和处理，否则可能会导致程序运行不稳定或者出现不可预知的问题。

为了处理ExecutorService中的异常和错误，你可以采用以下方法：

1. 使用try-catch语句：在执行任务时，可以使用try-catch语句来捕获和处理异常。例如：

ExecutorService executorService = Executors.newFixedThreadPool(10);

try {
    executorService.submit(() -> {
        // 你的任务代码
    });
} catch (Exception e) {
    e.printStackTrace();
}

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

ExecutorService executorService = Executors.newFixedThreadPool(10);
Future<?> future = executorService.submit(() -> {
    // 你的任务代码
});

try {
    future.get();
} catch (InterruptedException e) {
    // 处理线程中断异常
    e.printStackTrace();
} catch (ExecutionException e) {
    // 处理任务执行异常
    e.printStackTrace();
}

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((t, e) -> {
            // 处理线程异常
            e.printStackTrace();
        });
        return thread;
    }
}

// 使用自定义线程工厂创建ExecutorService
ExecutorService executorService = Executors.newFixedThreadPool(10, new CustomThreadFactory());

4. 使用ThreadPoolExecutor的自定义拒绝策略：当你使用ThreadPoolExecutor时，可以自定义一个拒绝策略来处理无法接受的任务。例如，你可以创建一个自定义的RejectedExecutionHandler，在任务被拒绝时处理异常。

public class CustomRejectedExecutionHandler implements RejectedExecutionHandler {
    @Override
    public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
        // 处理无法接受的任务
        System.out.println("任务被拒绝: " + r.toString());
    }
}

// 使用自定义拒绝策略创建ThreadPoolExecutor
ThreadPoolExecutor executorService = new ThreadPoolExecutor(
        10, 20, 60L, TimeUnit.SECONDS,
        new LinkedBlockingQueue<>(100),
        new CustomRejectedExecutionHandler()
);

通过以上方法，你可以有效地处理ExecutorService中的异常和错误，保证程序的稳定运行。