如何正确捕获 Executor 中的 RuntimeException？

Question

假设我有以下代码：

ExecutorService executor = Executors.newSingleThreadExecutor();
executor.execute(myRunnable);

现在，如果 myRunnable 抛出 RuntimeExcpetion，我怎样才能捕获它？一种方法是为 newSingleThreadExecutor() 提供我自己的 ThreadFactory 实现，并为 Thread 设置自定义 uncaughtExceptionHandler是从中出来的。另一种方法是将 myRunnable 包装到包含 try-catch 块的本地（匿名）Runnable。也许还有其他类似的解决方法。但是……不知怎的，这感觉很脏，我觉得不应该这么复杂。有干净的解决方案吗？

Answer 1

干净的解决方法是使用 ExecutorService.submit() 而不是 execute()。这将返回一个 Future，您可以使用它来检索任务的结果或异常：

ExecutorService executor = Executors.newSingleThreadExecutor();
Runnable task = new Runnable() {
  public void run() {
    throw new RuntimeException("foo");
  }
};

Future<?> future = executor.submit(task);
try {
  future.get();
} catch (ExecutionException e) {
  Exception rootException = e.getCause();
}

Answer 2

在另一个可捕获运行时异常并处理它们的可运行对象中装饰可运行对象：

public class REHandler implements Runnable {
    Runnable delegate;
    public REHandler (Runnable delegate) {
        this.delegate = delegate;
    }
    public void run () {
        try {
            delegate.run ();
        } catch (RuntimeException e) {
            ... your fancy error handling here ...
        }
    }
}

executor.execute(new REHandler (myRunnable));

Answer 3

为什么不调用 ExecutorService#submit()，获取Future 返回，然后在调用 Future#get() ？

Answer 4

skaffman 是正确的，因为使用 submit 是最干净的方法。另一种方法是子类 ThreadPoolExecutor< /code>并覆盖 afterExecute(Runnable, Throwable)。如果您遵循此方法，请务必调用 execute(Runnable) 而不是 submit(Runnable) 或 afterExecute不被调用。

根据 API 描述：

完成后调用的方法
执行给定的 Runnable。这
方法由线程调用
执行任务。如果非空，则
可抛出的是未捕获的
导致的 RuntimeException 或 Error
执行突然终止。

注意：当动作包含在
任务（例如 FutureTask）
明确地或通过诸如
提交，这些任务对象捕获并
维护计算异常，以及
所以它们不会造成突然的
终止，以及内部
异常不会传递给此
方法。

Answer 5

提交到 ThreadPoolExecutors 的任务（Callable 或 Runnable）将被转换为 FuturnTask，包含一个名为 < b>callable 等于您提交的任务。 FuturnTask 有自己的 run 方法，如下所示。 c.call() 中抛出的所有异常或可抛出异常都将被捕获并放入名为 outcome 的 prop 中。 将会抛出outcome

FuturnTask.run From Jdk1.8 Source Code ：

public void run() {
        ...
        try {
            Callable<V> c = callable;
            if (c != null && state == NEW) {
                V result;
                boolean ran;
                try {
                    result = c.call();
                    ran = true;
                } catch (Throwable ex) {
                    result = null;
                    ran = false;
                    // save ex into `outcome` prop
                    setException(ex);
                }
                if (ran)
                    set(result);
            }
        }
        ...
    }

当调用FuturnTask的get方法时，如果你想捕获异常，

1. skaffman's answer
2. overwrite `afterExecute` when you new a ThreadPoolExecutor

        @Override
        protected void afterExecute(Runnable r, Throwable t) {
            super.afterExecute(r, t);
            Throwable cause = null;
            if (t == null && r instanceof Future) {
                try {
                    ((Future<?>) r).get();
                } catch (InterruptedException | ExecutionException e) {
                    cause = e;
                }
            } else if (t != null) {
                cause = t;
            }
            if (cause != null) {
                // log error
            }
        }