Java Executor如何处理任务异常

在Java中，当使用ExecutorService执行任务时，如果任务抛出异常，那么这个异常通常会被ThreadPoolExecutor的afterExecute方法捕获。默认情况下，这个异常会被打印到System.err，但是你可以通过重写afterExecute方法来自定义异常处理逻辑。

以下是一个简单的例子，展示了如何创建一个自定义的ThreadPoolExecutor，并重写afterExecute方法来处理任务异常：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class CustomThreadPoolExecutor extends ThreadPoolExecutor {

    public CustomThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit) {
        super(corePoolSize, maximumPoolSize, keepAliveTime, unit);
    }

    @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) {
            // 自定义异常处理逻辑
            System.err.println("任务异常: " + t.getMessage());
        }
    }

    public static void main(String[] args) {
        CustomThreadPoolExecutor executorService = new CustomThreadPoolExecutor(2, 4, 60, TimeUnit.SECONDS);

        executorService.submit(() -> {
            throw new RuntimeException("测试异常");
        });

        executorService.shutdown();
    }
}

在这个例子中，我们创建了一个名为CustomThreadPoolExecutor的自定义线程池执行器，它继承自ThreadPoolExecutor。我们重写了afterExecute方法，以便在任务执行完成后检查是否有异常发生。如果有异常，我们将其打印到System.err。

在main方法中，我们创建了一个CustomThreadPoolExecutor实例，并提交了一个会抛出异常的任务。当我们运行这个程序时，你会看到自定义的异常处理逻辑被执行，而不是默认的行为。