基于Spring定时任务的fixedRate和fixedDelay的区别-eolink官网

基于Spring定时任务的fixedRate和fixedDelay的区别

目录Spring定时任务的fixedRate和fixedDelay区别定时任务fixedRate和fixedDelay区别最简单的解释

Spring定时任务的fixedRate和fixedDelay区别

用过 Spring 的 @EnableScheduling 的都知道，我们用三种形式来部署计划任务，即 @Scheduled 注解的 fixedRate(fixedRateString), fixedDelay(fixedDelayString), 以及 cron. cron 不在这里讨论的范畴。我们着重在如何理解 fixedRate 和 fixedDelay 的区别。

在 Spring 的 Scheduled 注解的 javaDoc 对此的解释很简单

public abstract long fixedRate

Execute the annotated method with a fixed period in milliseconds between invocations.

public abstract long fixedDelay

Execute the annotated method with a fixed period in milliseconds between the end of the last invocation and the start of the next.

只是说是 fixedRate 任务两次执行时间间隔是任务的开始点，而 fixedDelay 的间隔是前次任务的结束与下次任务的开始。

大致用示意字符串来表示如下(每个 T1, 或 T2 代表任务执行秒数(每次任务执行时间不定)，假定 fixedRate 或 fixedDelay 的值是 5 秒，用 W 表示等待的数)

fixedRate: T1.T1WWWT2.T2.T2WW.T3.T3.T3.T3.T3.T4.T4.T4.T4.T4.T4.T4T5T5WWWT6.T6........

fixedDelay: T1.T1.WWWWW.T2.T2.T2WWWWW.T3.T3.T3.T3.T3.WWWWW.T4.T4.T4.T4.T4.T4.T4.WWWWWT6.T6......

一般来说能理解到上面两个场景已经差不多了，相比而言 fixedDelay 简单些，盯着上一次任务的屁股就行。

以前我对 fixedRate 还有一个误区就是，以为任务时长超过 fixedRate 时会启动多个任务实例，其实不会; 只不过会在上次任务执行完后立即启动下一轮。除非这个 Job 方法用 @Async 注解了，使得任务不在 TaskScheduler 线程池中执行，而是每次创建新线程来执行。

具体理解我们可以用代码来演示

@EnableScheduling

@SpringBootApplication

public class Application {

private AtomicInteger number = new AtomicInteger();

public static void main(String[] args) {

SpringApplication.run(Application.class, args);

}

@Bean

public TaskScheduler taskScheduler() {

ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();

taskScheduler.setPoolSize(5);

return taskScheduler;

}

@Scheduled(fixedRate = 5000)

public void job() {

LocalTime start = LocalTime.now();

System.out.println(Thread.currentThread() + " start " + number.incrementAndGet() + " @ " + start);

try {

ThreaPkIIZWLfwd.sleep(ThreadLocalRandom.current().nextInt(15) * 1000);

} catch (InterruptedException e) {

}

LocalTime end = LocalTime.now();

System.out.println(Thread.currentThread() + " end " + number.get() + " @ " + end

+ ", seconds cost " + (ChronoUnit.SECONDS.between(start, end)));

}

初始化了一个线程池大小为 5 的 TaskScheduler, 避免了所有任务都用一个线程来执行。上例中的 fixedRate 为 5 秒，任务执行时间在 0 ～ 15 秒之间，先来看一组数据(样本数据越多越生动)

把 start 行用红色显示。

任务 1 与 2 之间间隔时间是任务时长 13，所以任务 2 在 1 结束后立即启动

任务 3 与 2 之间间隔还不到 5 秒，也是在任务 2 结束后立即执行

后面都是在上次任务结束后立即执行下一次任务，看到 7 与 8 之间相差 0 秒，13 与 14 之间相关 2 秒

从上面的结果分析，似乎 fixedRate 越到后面都不起作用，总是任务一个接一个的执行。也就是说上面 fixedRate 的示意串

T1.T1WWWT2.T2.T2WW.T3.T3.T3.T3.T3.T4.T4.T4.T4.T4.T4.T4T5T5WWWT6.T6........

已经不成立了，当中间发生了一长时间的任务后，fixedRate 变成了如下的形式

T1.T1.WWWT2.T2.T2.T2.T2.T2.T2.T2.T2.T2.T2.T2.T3.T3.T3.T3.T4.T4.T4.T5.T5.T5.......

任务间的等待都被抹除掉了，这是为什么呢？因为 fixedRate 会对将要执行的任务作一个预先编排，由上输出可以第一次任务在 01:23:11 时间点启动，所以 fixedRate 会基于此把一个时间表准备好，如下