为什么调度执行器服务在引发异常后不再次运行任务?

2022-09-01 18:58:40

为了执行周期性任务,我查看了TimerSchpendentDThreadPoolExecutor(使用单个线程),并决定使用后者,因为在Experators.newSingleThreadScheduledExecutor()的参考中,它说:

但请注意,如果此单个线程由于关闭前的执行期间失败而终止,则如果需要执行后续任务,则将使用新线程取而代之。

我的计划是将此用作保护措施,以防止在要监视其他操作的监视狗代码段中出现未捕获的异常。我想确定并写了下面的测试,很快就失败了。看来我做出了错误的假设,还是我的测试出了问题?

代码如下:

@Test
public void testTimer() {
    final AtomicInteger cTries = new AtomicInteger(0);
    final AtomicInteger cSuccesses = new AtomicInteger(0);

    TimerTask task = new TimerTask() {
        @Override
        public void run()
        {
            cTries.incrementAndGet();
            if (true) {
                throw new RuntimeException();
            }
            cSuccesses.incrementAndGet();
        }
    };

    /*
    Timer t = new Timer();
    t.scheduleAtFixedRate(task, 0, 500);
     */
    ScheduledExecutorService exe = Executors.newSingleThreadScheduledExecutor();
    exe.scheduleAtFixedRate(task, 0, 500, TimeUnit.MILLISECONDS);
    synchronized (this) {
        try {
            wait(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
        }
    }
    exe.shutdown();
    /*
    t.purge();
     */
    Assert.assertEquals(cSuccesses.get(), 0);
    Assert.assertTrue(cTries.get() > 1, String.format("%d is not greater than 1. :(", cTries.get()));
}

答案 1

一旦重复任务引发未捕获的异常,就会假定它已死亡或处于错误状态。它也会默默地失败,除非你检查未来以获得错误/异常,这有点麻烦。

如果您不想终止重复任务,则必须捕获异常。


正如 Matt b 在上面的评论中指出的那样,

对于像这样的框架代码来说,假设它可以安全地重新启动失败的作业是有问题的 - 它失败并出现异常的事实意味着数据可能已处于任何类型的状态,并且重新启动作业可能是不安全的。


答案 2

马特b给出了原因。

对于像这样的框架代码来说,假设它可以安全地重新启动失败的作业是有问题的 - 它失败并出现异常的事实意味着数据可能已处于任何类型的状态,并且重新启动作业可能是不安全的。



应该注意的是,这是写在 ScheduledExecutorService 的文档中

如果任务的任何执行遇到异常,则禁止后续执行。

正如Michael Krusse所说,创建新线程的要点是允许其他任务继续运行。


推荐