Java Executor执行器如何处理异常

在Java中，当使用Executor执行器执行任务时，可能会遇到异常。为了处理这些异常，你可以采用以下方法：

1. 在任务内部捕获异常：在执行任务的Runnable或Callable实现中，使用try-catch语句捕获异常。这样，当异常发生时，你可以在catch块中处理它。

ExecutorService executorService = Executors.newFixedThreadPool(10);

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

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

ExecutorService executorService = Executors.newFixedThreadPool(10);

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

try {
    future.get();
} catch (InterruptedException e) {
    // 处理线程中断异常
    e.printStackTrace();
} catch (ExecutionException e) {
    // 处理任务抛出的异常
    e.getCause().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 = Executors.newFixedThreadPool(10, new CustomThreadFactory());

executorService.submit(() -> {
    // 你的任务代码
});

4. 使用ThreadPoolExecutor的afterExecute方法：如果你使用的是ThreadPoolExecutor，你可以重写afterExecute方法来处理任务执行后抛出的异常。

ThreadPoolExecutor executorService = new ThreadPoolExecutor(
        10, 10, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>()) {
    @Override
    protected void afterExecute(Runnable r, Throwable t) {
        super.afterExecute(r, t);
        if (t == null && r instanceof java.util.concurrent.Future<?>) {
            try {
                java.util.concurrent.Future<?> future = (java.util.concurrent.Future<?>) r;
                if (future.isDone()) {
                    future.get();
                }
            } catch (CancellationException ce) {
                t = ce;
            } catch (ExecutionException ee) {
                t = ee.getCause();
            } catch (InterruptedException ie) {
                Thread.currentThread().interrupt(); // ignore/reset
            }
        }
        if (t != null) {
            // 处理异常
            t.printStackTrace();
        }
    }
};

executorService.submit(() -> {
    // 你的任务代码
});

根据你的需求和应用场景，可以选择合适的方法来处理Java Executor执行器中的异常。