Springboot定时任务Scheduled重复执行操作
今天用scheduled写定时任务的时候发现定时任务一秒重复执行一次，而我的cron表达式为*0/2****。
在源码调试的过程中，发现是我的定时任务执行过程太短导致的。
于是我另外写了个简单的定时任务
@Component
publicclassTestJob{
@Scheduled(cron="*0/2****")
publicvoidtest(){
System.out.println("测试开始");
System.out.println("测试结束");
}
}
上述任务在启动之后一直执行。
然后我在任务后面加入线程睡眠1分钟。
@Component
publicclassTestJob{
@Scheduled(cron="*0/2****")
publicvoidtest(){
System.out.println("测试开始");
System.out.println("测试结束");
try{
Thread.sleep(60000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
System.out.println("睡眠结束");
}
}
上述任务执行一次就没有再执行了。
所以我继续深入查看源码，发现问题在于CronSequenceGenerator.class的next方法。
publicDatenext(Datedate){
Calendarcalendar=newGregorianCalendar();
calendar.setTimeZone(this.timeZone);
calendar.setTime(date);
//1.设置下次执行时间的毫秒为0，如上次任务执行过程不足1秒，则calendar的时间会被设置成上次任务的执行时间
calendar.set(14,0);
longoriginalTimestamp=calendar.getTimeInMillis();
this.doNext(calendar,calendar.get(1));
//2.由于有上面一步，执行时间太短，会导致下述条件为true
if(calendar.getTimeInMillis()==originalTimestamp){
//3.calendar在原来的时间上增加1秒
calendar.add(13,1);
//CronSequenceGenerator的doNext算法从指定时间开始(包括指定时间)查找符合cron表达式规则下一个匹配的时间
//注意第一个匹配符是*，由于增加了1秒，依然符合cron="*0/2****"，所以下一个执行时间就是在原来的基础上增加了一秒
this.doNext(calendar,calendar.get(1));
}
returncalendar.getTime();
}
请查看代码中的注释，由于任务执行时间太短了，代码会进入if语句，并设置执行时间在原来的基础上增加一秒。
但由于增加一秒后的时间戳依然符合cron表达式，于是在执行完代码后一秒，任务又开始执行了。
解决办法：
程序执行时间太短没有关系，只要cron表达式秒的匹配符不设置为*就可以了。
cron表达式可以设置为"00/2****"，这样在执行到next方法中的doNext方法时就会发现时间增加1秒不符合cron表达式了，从而去寻找下一个合适的执行时间。
补充知识：SpringBoot定时器/定时任务：在一个指定的周期时间内，执行某一项任务。
说多都是累，直接上代码：
实现方式有三种(可能还有更多的实现，这三种只是楼主目前所知道的)：
1、静态定时器，无法修改周期
@Configuration("myScheduled")
@EnableScheduling
publicclassScheduledDemo{
//每10秒执行一次
@Scheduled(cron="0/10****?")
publicvoidtimmer(){
System.out.println("执行任务");
}
}
2、动态定时器
//通过setCron方法修改任务周期
@Component("myScheduled")
publicclassScheduledDemoimplementsSchedulingConfigurer{
//默认的任务周期为10秒
privateStringcron="0/10****?";
@Override
publicvoidconfigureTasks(ScheduledTaskRegistrartaskRegistrar){
//TODOAuto-generatedmethodstub
taskRegistrar.addTriggerTask(newRunnable(){
@Override
publicvoidrun(){
//TODOAuto-generatedmethodstub
System.out.println("执行任务");
}
},newTrigger(){
@Override
publicDatenextExecutionTime(TriggerContexttriggerContext){
returnnewCronTrigger(cron).nextExecutionTime(triggerContext);
}
});
}
publicvoidsetCron(Stringcron){
this.cron=cron;
}
}
3、动态定时器：多线程定时任务执行，可以设置执行线程池数（默认一个线程）
@Component("myScheduled")
publicclassScheduledImpl{
privateScheduledFuturefuture;
@Autowired
privateThreadPoolTaskSchedulerthreadPoolTaskScheduler;
@Bean
publicThreadPoolTaskSchedulerthreadPoolTaskScheduler(){
returnnewThreadPoolTaskScheduler();
}
@Override
publicvoidsetCron(finalStringcron){
stopCron();
future=threadPoolTaskScheduler.schedule(newRunnable(){
@Override
publicvoidrun(){
//TODOAuto-generatedmethodstub
System.out.println("执行任务");
}
},newTrigger(){
@Override
publicDatenextExecutionTime(TriggerContexttriggerContext){
if(cron==null||"".equals(cron)){
returnnull;
}
CronTriggercronTrigger=newCronTrigger(cron);
returncronTrigger.nextExecutionTime(triggerContext);
}
});
}
@Override
publicvoidstopCron(){
if(future!=null){
future.cancel(true);
}
}
}
cron的参数说明，详细说明直接网上搜吧！
大概说明：秒分时日月星期年（可省略）
/后面表示周期
-表示范围
星期一般用?，为了防止和日混淆，如果星期有值，则日用?
“0/10****?”表示每10秒
“00/10***?”表示每10分
以上这篇Springboot定时任务Scheduled重复执行操作就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持毛票票。