聊聊SpringBoot的@Scheduled的并发问题

下面是详细讲解SpringBoot的@Scheduled的并发问题的完整攻略。

什么是@Scheduled

@Scheduled是Spring框架中用于定时任务的注解。使用该注解可以实现在指定的时间间隔或特定时间执行代码块。

@Schedule的并发问题

在使用@Scheduled注解时，可能会出现并发的问题。在Spring Boot 2.x版本中，@Scheduled注解默认为serial(串行)模式，即任务一定会等待上一个任务执行完成后再执行。但是在Spring Boot 1.x版本中，@Scheduled注解默认并发执行任务，不会进行等待。

因此，我们需要合理地配置@Scheduled注解的并发策略，以避免出现意外的并发问题。

并发策略

1. SERIAL默认串行模式

串行模式的特点是一个任务执行完毕后，才会执行下个任务。这种模式比较适合那些需要考虑线程安全和数据一致性的场景。

在Spring Boot 2.x中，@Scheduled注解默认使用串行模式，所以不需要额外配置。

示例代码：

@Component
public class MyScheduledTasks {

    @Scheduled(fixedRate = 1000)
    public void task1() {
        System.out.println(Thread.currentThread().getName() + " task1 执行时间：" + new Date());
    }

    @Scheduled(fixedRate = 1000)
    public void task2() {
        System.out.println(Thread.currentThread().getName() + " task2 执行时间：" + new Date());
    }
}

以上示例代码中，task1和task2均使用了@Scheduled注解，并设置了相同的执行周期为1000毫秒。根据串行模式特性，task1执行完毕后，才会开始执行task2。

输出结果如下所示：

pool-1-thread-1 task1 执行时间：Wed Aug 25 10:44:53 CST 2021
pool-1-thread-1 task2 执行时间：Wed Aug 25 10:44:54 CST 2021
pool-1-thread-1 task1 执行时间：Wed Aug 25 10:44:54 CST 2021
pool-1-thread-1 task2 执行时间：Wed Aug 25 10:44:55 CST 2021
pool-1-thread-1 task1 执行时间：Wed Aug 25 10:44:55 CST 2021
pool-1-thread-1 task2 执行时间：Wed Aug 25 10:44:56 CST 2021

可以看到，task1和task2交替执行，且每个任务都等待上一个任务执行完毕后再开始执行。

1. CONCURRENT并发模式

并发模式的特点是任务可以同时执行，不需要等待别的任务执行完毕之后再开始执行。但是这样会有一些风险，比如并发情况下可能会存在数据不一致的问题。

在Spring Boot 1.x版本中，@Scheduled注解默认使用并发模式，我们需要通过配置文件进行修改，将其改为串行模式。

在Spring Boot 2.x版本中，为了避免并发问题，@Scheduled注解新增了一个属性——mode，用来控制任务并发模式，可以配置为SERIAL或CONCURRENT。

示例代码：

@Component
public class MyScheduledTasks {

    @Scheduled(fixedRate = 1000, mode = TaskExecutionMode.CONCURRENT)
    public void task1() {
        System.out.println(Thread.currentThread().getName() + " task1 执行时间：" + new Date());
    }

    @Scheduled(fixedRate = 1000, mode = TaskExecutionMode.CONCURRENT)
    public void task2() {
        System.out.println(Thread.currentThread().getName() + " task2 执行时间：" + new Date());
    }
}

以上示例代码中，task1和task2都使用了@Scheduled注解，并设置了相同的执行周期为1000毫秒，并且将mode属性配置为TaskExecutionMode.CONCURRENT。

输出结果如下所示：

scheduling-1 task1 执行时间：Wed Aug 25 10:29:48 CST 2021
scheduling-1 task2 执行时间：Wed Aug 25 10:29:48 CST 2021
scheduling-1 task1 执行时间：Wed Aug 25 10:29:49 CST 2021
scheduling-1 task2 执行时间：Wed Aug 25 10:29:49 CST 2021
scheduling-1 task1 执行时间：Wed Aug 25 10:29:50 CST 2021
scheduling-1 task2 执行时间：Wed Aug 25 10:29:50 CST 2021

可以看到，task1和task2几乎同时执行，没有等待别的任务执行完毕之后再开始执行。

总结

在使用@Scheduled注解时，必须要考虑到并发的问题。可以通过配置@Scheduled注解的mode属性来控制任务的并发模式，以避免出现意外的并发问题。同时，在实际的开发中，还应该考虑到任务的线程安全性和数据一致性问题。