SpringBoot中使用SpringTask处理定时任务,这是一种相较于传统的quartZ组件更加简单的形式,在方法上使用@Scheduled
注解可以设置定时任务,任务分为3种类型。
No. | 类型 | 解释 |
---|---|---|
1 | fixedDelay | 每次任务执行完之后的xx时间后继续执行,单位为ms |
2 | fixedRate | 固定时间循环执行,单位为ms |
3 | cron | 当时间达到设置的时间会触发任务 |
其中cron任务需要编写cron表达式,也可以选择在网站快速生成(快速生成cron表达式)。
新建一个定时任务类并注册到Spring容器中,设置三种任务类型。
@Component
@Slf4j
public class SpringScheduleTask {
private final SimpleDateFormat FORMAT = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
@Scheduled(fixedDelay=2000) // 表示任务执行完成后推迟2s继续执行。
public void fixedDelay() {
log.info("【fixedDelay】" + FORMAT.format(new Date()));
}
@Scheduled(fixedRate=2000) //表示每2s执行一次时间,程序启动时开始。
public void fixedRate() {
log.info("【fixedRate】" + FORMAT.format(new Date()));
}
@Scheduled(cron="* * * * * ?") // 每秒执行一次
public void cron() {
log.info("【cron】" + FORMAT.format(new Date()));
}
}
在SpringBoot启动类添加@EnableScheduling
注解开启定时任务支持,启动程序。
将fixedDelay方法修改为休眠20s,再次执行。
@Scheduled(fixedDelay=2000) // 表示任务执行完成后推迟2s继续执行。
public void fixedDelay() {
log.info("【fixedDelay】" + FORMAT.format(new Date()));
try {
TimeUnit.SECONDS.sleep(20); // 睡眠20s
} catch (InterruptedException exception) {
exception.printStackTrace();
}
}
观察任务的执行发现,由于fixedDelay中的延时,导致其它任务的执行也出现了推迟。
这是由于执行任务的线程池中只开启了一个线程,线程的休眠一定会影响其它任务的执行,应当修改线程池配置,增加线程数量。
@Configuration
public class ScheduleTaskConfig implements SchedulingConfigurer {
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
taskRegistrar.setScheduler(Executors.newScheduledThreadPool(3)); // 设置线程数量为3
}
}
版权说明 : 本文为转载文章, 版权归原作者所有 版权申明
原文链接 : https://blog.csdn.net/Nicholas_GUB/article/details/121563988
内容来源于网络,如有侵权,请联系作者删除!