1.Spring Task Scheduler介绍

Spring Scheduler里有两个概念：任务（Task）和运行任务的框架（TaskExecutor/TaskScheduler）。TaskExecutor顾名思义，是任务的执行器，允许我们异步执行多个任务。TaskScheduler是任务调度器，来运行未来的定时任务。触发器Trigger可以决定定时任务是否该运行了，最常用的触发器是CronTrigger，具体用法会在下面章节中详细介绍。Spring内置了多种类型的TaskExecutor和TaskScheduler，方便用户根据不同业务场景选择。

开启定时任务

Spring Boot 默认在无任何第三方依赖的情况下使用 spring-context 模块下提供的定时任务工具 Spring Task。我们只需要使用 @EnableScheduling 注解就可以开启相关的定时任务功能。如：

2.各种定时器实现

cron定时器

注解方式

/** *  ┌───────────── second (0-59) *  │ ┌───────────── minute (0 - 59) *  │ │ ┌───────────── hour (0 - 23) *  │ │ │ ┌───────────── day of the month (1 - 31) *  │ │ │ │ ┌───────────── month (1 - 12) (or JAN-DEC) *  │ │ │ │ │ ┌───────────── day of the week (0 - 7) *  │ │ │ │ │ │          (0 or 7 is Sunday, or MON-SUN) *  │ │ │ │ │ │ *  * * * * * * * */@Scheduled(cron="*/5 * * * * MON-FRI")public void doSomething() {    log.info("cron ....");}

代码方式

public void scheduleCronTrigger() {    CronTrigger cronTrigger = new CronTrigger("10 * * * * ?");    taskScheduler.schedule(new RunnableTask("Cron Trigger"), cronTrigger);}

scheduleWithFixedDelay

注解实现

@Scheduled(initialDelay = 5000, fixedRate = 5000)public void performTask1() {    log.info("Task performed at {}", LocalDateTime.now());}

代码实现

public void scheduleWithFixedDelay() {    taskScheduler.scheduleWithFixedDelay(new RunnableTask("Fixed 1 second Delay"), 1000);}

scheduleAtFixedRate

注解方式

@Scheduled(fixedRate = 5000)public void performTask() {    log.info("Task performed at {}", LocalDateTime.now());}

代码实现

public void scheduleAtFixedRate() {    taskScheduler.scheduleAtFixedRate(new RunnableTask("Fixed Rate of 2 seconds") , 2000);}

配置定时器线程池

package com.et.scheduler.config;
import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
@Configurationpublic class ThreadPoolTaskSchedulerConfig {
    @Bean    public ThreadPoolTaskScheduler threadPoolTaskScheduler(){        ThreadPoolTaskScheduler threadPoolTaskScheduler          = new ThreadPoolTaskScheduler();        threadPoolTaskScheduler.setPoolSize(5);        threadPoolTaskScheduler.setThreadNamePrefix(          "ThreadPoolTaskScheduler");        return threadPoolTaskScheduler;    }}

以上只是一些关键代码，所有代码请参见下面代码仓库

代码仓库

https://github.com/Harries/springboot-demo

3.局限性

同时运行

同一个task，如果前一个还没跑完后面一个就不会触发，这没有问题。但是不同的task也不能同时运行就不太合理了。不过其实是scheduler的默认线程数为1的缘故。

分布式不支持

scheduler会在多个实例上同时运行。此时可以选择分布式定时任务框架如：xxl-job，quartz等等

4.总结

TaskScheduler是Spring框架中非常有用的一个接口，它可以帮助我们实现定时任务、周期性任务和异步任务等。通过本文的介绍和举例说明，相信读者对TaskScheduler的使用方法有了更深入的了解。在实际项目中，我们可以根据具体需求选择合适的TaskScheduler实现类，并通过注解的方式来配置和使用TaskScheduler，从而更好地管理和执行任务。

ITPub博客

Spring Boot集成Spring Task Scheduler快速入门demo