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;@Configuration
public class ThreadPoolTaskSchedulerConfig {@Beanpublic 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，从而更好地管理和执行任务。
