如何通知主线程 ScheduledExecutor 任务线程中发生的异常？

Question

我在 ScheduledExecutor< 中有一个任务/code>定期运行。如果我想将特定的异常归结到主线程，那么有什么干净的方法可以做到这一点？似乎没有办法从 ScheduledFuture 捕获异常，如果我只是尝试在计划任务上抛出 RuntimeException，该任务将停止并且永远不会由 ScheduledExecutor 再次运行。

目前，我在主线程中只有一个公共静态成员，用于接收来自计划任务的事件，但这似乎不太理想。有什么推荐的读物供我查看或有什么想法吗？

编辑：抱歉，请允许我用一个例子来扩展这一点：

public class TestScheduledFuture {

    public static void main(String[] args) {
        ScheduledExecutorService taskScheduler = Executors.newSingleThreadScheduledExecutor();
        ScheduledFuture<?> scheduledFuture = taskScheduler.scheduleAtFixedRate(new TestScheduledTask(),2,2, TimeUnit.SECONDS);
    }
}

如果我在 TestScheduledTask() 中遇到 RuntimeException，我的目标是简单地在 main() 中抛出 RuntimeException() 。

现在，我在主类中有一个公共静态并发队列，我从计划线程中添加异常。在 main() 中，我只是定期轮询队列并对队列中的任何异常做出反应。有更好的方法吗？

Answer 1

老实说，通过队列将异常传递回另一个线程似乎是一件完全合理的事情。正如见解者所说，另一种方法是使用 Thread.setUncaughtExceptionHandler ，否则异常将不会被 ExecutorService 处理。要使用它，您需要在创建它时提供一个 ThreadFactory ，如下所示

class MyThreadFactory implements ThreadFactory {
    private final ThreadFactory DEFAULT_THREAD_FACTORY = Executors.defaultThreadFactory();

    public Thread newThread(Runnable r) {
        Thread thread = DEFAULT_THREAD_FACTORY.newThread(r);
        thread.setUncaughtExceptionHandler(new MyUncaughtExceptionHandler());
        return thread;
    }
};


class MyUncaughtExceptionHandler implements Thread.UncaughtExceptionHandler {
    public void uncaughtException(Thread t, Throwable e) {
        // give this a reference to main so it can call some method to pass e and t back 
    }
}

Answer 2

Thread.setDefaultUncaughtExceptionHandler