ScheduledExecutorService定时任务停止问题

柔情只为你懂 2024-03-30 14:37 109阅读 0赞

#### 文章目录 ####

*  前言
 *  一、ScheduledExecutorService\#scheduleAtFixedRate方法注释
 *  二、本地验证
 *   *  1.不捕获异常
     *  2.捕获异常（注意使用Throwable）

--------------------

## 前言 ##

最近开市场问题，发现程序中同时开启的四个定时任务只有一个还在执行，后面跟踪原因，发现是ScheduledExecutorService在遇到异常时候会抑制后续任务的执行。

--------------------

## 一、ScheduledExecutorService\#scheduleAtFixedRate方法注释 ##

![在这里插入图片描述][e31dc2ccf082452b8beb0e1a8d7cc1b2.png_pic_center]  
后半段主要说明以下三点：

1.  如果某一次过程中产生异常，则会抑制后续任务的执行
2.  正常情况下，该定时任务只会通过取消和终止执行者停止
3.  如果一次任务的实际执行时间比方法中给定的周期还长，那么下次任务会等该次任务执行结束后再开始，且保证不会并发执行

## 二、本地验证 ##

### 1.不捕获异常 ###

代码如下（示例）：

public static void main11() {
        
        ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);
        LongAdder longAdder = new LongAdder();
        scheduledExecutorService.scheduleAtFixedRate(() -> {
        
            longAdder.add(1L);
            System.out.println(longAdder.longValue() + " 次任务开始执行");
            if (longAdder.longValue() >= 3) {
        
                System.err.println(longAdder.longValue() + " 次任务执行过程中抛出异常");
                System.err.println("异常" + 1 / 0);
            }
        }, 1, 1, TimeUnit.MILLISECONDS);
    }

运行结果：  
![在这里插入图片描述][c2eba50b176443bf86c51a659af6056d.png_pic_center]  
任务还在继续运行，但是后续的执行因为异常的产生被抑制。

### 2.捕获异常（注意使用Throwable） ###

代码如下（示例）：

public static void main12() {
        
        ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);
        LongAdder longAdder = new LongAdder();
        scheduledExecutorService.scheduleAtFixedRate(() -> {
        
            longAdder.add(1L);
            System.out.println(longAdder.longValue() + " 次任务开始执行");
            if (longAdder.longValue() >= 3) {
        
                // 增加了try-catch，注意这里最好使用Throwable，防止漏掉Error
                try {
        
                    System.err.println("构造异常" + 1 / 0);
                } catch (Throwable e) {
        
                    System.err.println(longAdder.longValue() + " 次任务执行过程中抛出异常" + e.getMessage());
                }
            }
        }, 1, 1, TimeUnit.MILLISECONDS);
    }

运行结果：  
![在这里插入图片描述][f3569c1467ef46cc9d4aad5bafe659c4.png_pic_center]  
手动停止进程后，进行截图，如果不手动停止该任务一直运行。

--------------------

[e31dc2ccf082452b8beb0e1a8d7cc1b2.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/87d383477d4e4a109d9e347fe547ffe6.png
[c2eba50b176443bf86c51a659af6056d.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/76f72acf70cc4d33b30c23ae2669a8f8.png
[f3569c1467ef46cc9d4aad5bafe659c4.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/30/6e82dc1c7abb4ad5ac53ab2175b1be7c.png