ScheduledExecutorService scheduleAtFixedRate抛出异常后定时任务不会再执行源码分析

2024-04-20 09:17:10 浏览数 (3)

        ScheduledExecutorService有时会被用来实现本地的定期任务执行,常规使用方式如下所示:

代码语言:javascript复制
scheduledExecutorService.scheduleAtFixedRate(() -> {
    System.out.println("执行调度");
    Integer a = null;
    a.toString();
    System.out.println("调度结束");
    
}, 0, 1, TimeUnit.SECONDS);

但是需要注意的是如果上面的执行任务抛出异常后,后面的定时任务就不会再执行了,所以在使用 ScheduledExecutorService进行定时任务处理时,一定要对可能出现的异常进行捕获,下面分析下为什么会出现上面的原因。

下面看下核心代码ScheduledThreadPoolExecutor$.ScheduledFutureTask:

看下该类的run方法

代码语言:javascript复制
public void run() {
    if (!canRunInCurrentRunState(this))
        cancel(false);
    else if (!isPeriodic())
        super.run();
    else if (super.runAndReset()) {
         // 任务方法抛出异常时runAndReset返回false,下面的方法都不执行,这就是为什么定时任务抛出异常后定时任务不再执行的原因
        setNextRunTime();
        reExecutePeriodic(outerTask);
    }
}

PS:

最恶心的是这里面的异常信息还不会打印出来,所以抛出异常时你可能都不知道,所以使用时要特别注意!

0 人点赞