java - 处理 Java ExecutorService 任务的异常

Question

我正在尝试使用 Java 的 ThreadPoolExecutor 类以固定数量的线程运行大量重量级任务。每个任务都有很多地方可能会因异常而失败。

我对 ThreadPoolExecutor 进行了子类化，并重写了 afterExecute 方法，该方法应该提供运行任务时遇到的任何未捕获的异常。但是，我似乎无法让它发挥作用。

例如:

public class ThreadPoolErrors extends ThreadPoolExecutor {
    public ThreadPoolErrors() {
        super(  1, // core threads
                1, // max threads
                1, // timeout
                TimeUnit.MINUTES, // timeout units
                new LinkedBlockingQueue<Runnable>() // work queue
        );
    }

    protected void afterExecute(Runnable r, Throwable t) {
        super.afterExecute(r, t);
        if(t != null) {
            System.out.println("Got an error: " + t);
        } else {
            System.out.println("Everything's fine--situation normal!");
        }
    }

    public static void main( String [] args) {
        ThreadPoolErrors threadPool = new ThreadPoolErrors();
        threadPool.submit( 
                new Runnable() {
                    public void run() {
                        throw new RuntimeException("Ouch! Got an error.");
                    }
                }
        );
        threadPool.shutdown();
    }
}

该程序的输出是“一切都很好——情况正常!”即使提交到线程池的唯一 Runnable 抛出异常。对这里发生的事情有任何线索吗？

谢谢!

Answer 1

警告:需要注意的是，此解决方案将阻塞 future.get() 中的调用线程。

<小时/>

如果要处理任务抛出的异常，那么通常最好使用Callable而不是Runnable。

Callable.call() 允许抛出已检查的异常，并且这些异常会传播回调用线程:

Callable task = ...
Future future = executor.submit(task);
// do something else in the meantime, and then...
try {
   future.get();
} catch (ExecutionException ex) {
   ex.getCause().printStackTrace();
}

如果Callable.call()抛出异常，该异常将被包装在ExecutionException中并由Future.get()抛出。

这可能比子类化 ThreadPoolExecutor 更可取。如果异常是可恢复的，它还使您有机会重新提交任务。