线程池中的异常处理

Question

我有一个 ScheduledThreadPoolExecutor 似乎正在吃异常。我希望我的执行器服务在提交的 Runnable 抛出异常时通知我。

例如，我希望下面的代码至少打印 IndexArrayOutOfBoundsException 的 stackTrace

threadPool.scheduleAtFixedRate(
  new Runnable() {
    public void run() {
      int[] array = new array[0];
      array[42] = 5;
    }
  },
  1000,
  1500L,
  TimeUnit.MILLISECONDS);

作为附带问题。有没有办法为 ScheduledThreadPoolExecutor 编写通用的 try catch 块？

//////////原始问题结束 ///////////////

正如建议的，以下装饰器效果很好。

public class CatcherTask implements Runnable{

    Runnable runMe;

    public CatcherTask(Runnable runMe) {
        this.runMe = runMe;
    }

    public void run() {
        try {
            runMe.run();
        } catch (Exception ex){
            ex.printStackTrace();
        }
    }
}

Answer 1

我写了一个小不久前发布了关于此问题的帖子。您有两种选择：

1. 使用 Colin Herbert 提供的解决方案或
2. 使用修改后的解决方案Mark Peters 解决方案的版本，但不是分配 UncaughtExceptionHandler 将每个提交的 runnable 包装到您自己的 runnable 中，该 runnable 在 try-catch 块内执行（调用 run）真正的 runnable。

编辑
正如 Mark 所指出的，包装传递给 ScheduledExecutorService 的 Runnable 而不是传递给 ThreadFactory 的 Runnable 非常重要。

Answer 2

警告：此方法不适用于预定线程池执行器。由于与其他线程池执行器的相关性，该答案已被取消删除。请参阅威利的回答。

重写 ThreadFactory 为线程提供 UncaughtExceptionHandler：

ThreadPoolExecutor exec = new ThreadPoolExecutor...;

exec.setThreadFactory(new ExceptionCatchingThreadFactory(exec.getThreadFactory()));
//go on to submit tasks...


private static class ExceptionCatchingThreadFactory implements ThreadFactory {
    private final ThreadFactory delegate;

    private ExceptionCatchingThreadFactory(ThreadFactory delegate) {
        this.delegate = delegate;
    }

    public Thread newThread(final Runnable r) {
        Thread t = delegate.newThread(r);
        t.setUncaughtExceptionHandler(new UncaughtExceptionHandler() {
            @Override
            public void uncaughtException(Thread t, Throwable e) {
                e.printStackTrace();  //replace with your handling logic.
            }
        });
        return t;
    }
}

Answer 3

您可以使用通过调用 scheduleAtFixedRate() 获得的 Future 中的 get() 方法。如果线程执行期间发生异常，它将抛出 ExecutionException。

Answer 4

您还可以使用 “nofollow">Spring 框架，它公开了一个方法来设置错误处理程序并为您完成所有包装。默认行为取决于任务类型：

如果提供的 ErrorHandler 不为 null，则将使用它。否则，默认情况下，重复任务将抑制错误，而默认情况下一次性任务将传播错误，因为这些错误可能是通过返回的 Future 预期的。在这两种情况下，都会记录错误。

如果您只想使用包装部分而不是 TaskScheduler，则可以使用

TaskUtils.decorateTaskWithErrorHandler(task, errorHandler, isRepeatingTask)

TaskScheduler 在内部使用的内容。

Answer 5

您可以子类化 ScheduledThreadPoolExecutor 并覆盖 afterExecute 方法来处理您提交的任何类型的 Runnable 的异常和错误。

Answer 6

考虑在您的 ScheduledThreadPoolExecutor 类中添加一个静态事件，如果抛出异常，您的任何任务都可以调用该事件。这样，您就可以利用该事件来捕获和处理线程中发生的异常。