时间:2021-05-20
今天用scheduled写定时任务的时候发现定时任务一秒重复执行一次,而我的cron表达式为 * 0/2 * * * * 。
在源码调试的过程中,发现是我的定时任务执行过程太短导致的。
于是我另外写了个简单的定时任务
@Componentpublic class TestJob { @Scheduled(cron = "* 0/2 * * * *") public void test() { System.out.println("测试开始"); System.out.println("测试结束"); }}上述任务在启动之后一直执行。
然后我在任务后面加入线程睡眠1分钟。
@Componentpublic class TestJob { @Scheduled(cron = "* 0/2 * * * *") public void test() { System.out.println("测试开始"); System.out.println("测试结束"); try { Thread.sleep(60000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("睡眠结束"); }}上述任务执行一次就没有再执行了。
所以我继续深入查看源码,发现问题在于CronSequenceGenerator.class的next方法。
public Date next(Date date) { Calendar calendar = new GregorianCalendar(); calendar.setTimeZone(this.timeZone); calendar.setTime(date); //1.设置下次执行时间的毫秒为0,如上次任务执行过程不足1秒,则calendar的时间会被设置成上次任务的执行时间 calendar.set(14, 0); long originalTimestamp = 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)); } return calendar.getTime(); }请查看代码中的注释,由于任务执行时间太短了,代码会进入if语句,并设置执行时间在原来的基础上增加一秒。
但由于增加一秒后的时间戳依然符合cron表达式,于是在执行完代码后一秒,任务又开始执行了。
解决办法:
程序执行时间太短没有关系,只要cron表达式秒的匹配符不设置为*就可以了。
cron表达式可以设置为"0 0/2 * * * *",这样在执行到next方法中的doNext方法时就会发现时间增加1秒不符合cron表达式了,从而去寻找下一个合适的执行时间。
补充知识:SpringBoot 定时器/定时任务:在一个指定的周期时间内,执行某一项任务。
说多都是累,直接上代码:
实现方式有三种(可能还有更多的实现,这三种只是楼主目前所知道的):
1、静态定时器,无法修改周期
@Configuration("myScheduled")@EnableSchedulingpublic class ScheduledDemo{ //每10秒执行一次 @Scheduled(cron="0/10 * * * * ?") public void timmer(){ System.out.println("执行任务"); }}2、动态定时器
//通过setCron 方法修改 任务周期@Component("myScheduled")public class ScheduledDemo implements SchedulingConfigurer{ //默认的任务周期为 10秒 private String cron = "0/10 * * * * ?"; @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { // TODO Auto-generated method stub taskRegistrar.addTriggerTask(new Runnable() { @Override public void run() { // TODO Auto-generated method stub System.out.println("执行任务"); } }, new Trigger() { @Override public Date nextExecutionTime(TriggerContext triggerContext) { return new CronTrigger(cron).nextExecutionTime(triggerContext); } }); } public void setCron(String cron) { this.cron = cron; }}3、动态定时器:多线程定时任务执行,可以设置执行线程池数(默认一个线程)
@Component("myScheduled")public class ScheduledImpl{ private ScheduledFuture<?> future; @Autowired private ThreadPoolTaskScheduler threadPoolTaskScheduler; @Bean public ThreadPoolTaskScheduler threadPoolTaskScheduler() { return new ThreadPoolTaskScheduler(); } @Override public void setCron(final String cron) { stopCron(); future = threadPoolTaskScheduler.schedule(new Runnable() { @Override public void run() { // TODO Auto-generated method stub System.out.println("执行任务"); } }, new Trigger() { @Override public Date nextExecutionTime(TriggerContext triggerContext) { if(cron==null || "".equals(cron)) { return null; } CronTrigger cronTrigger = new CronTrigger(cron); return cronTrigger.nextExecutionTime(triggerContext); } }); } @Override public void stopCron() { if(future!=null) { future.cancel(true); } } }cron 的参数说明,详细说明直接网上搜吧!
大概说明:秒 分 时 日 月 星期 年(可省略)
/ 后面表示周期
- 表示范围
星期一般用 ? ,为了防止和 日 混淆,如果星期有值,则日用 ?
“0/10 * * * * ?”表示每10秒
“0 0/10 * * * ?”表示每10分
以上这篇Springboot定时任务Scheduled重复执行操作就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
在SpringBoot项目中,通过@EnableScheduling可启用Spring自带的定时任务支持,在通过@Scheduled注解定义定时任务,但是通过注
Spring提供了@Scheduled注解用于定时任务。一、@Scheduled的基本使用启用调度支持:@EnableScheduling可以将@Schedul
序言使用SpringBoot创建定时任务非常简单,目前主要有以下三种创建方式:一、基于注解(@Scheduled)二、基于接口(SchedulingConfig
@schedule注解是springboot常用的定时任务注解,使用起来简单方便,但是如果定时任务非常多,或者有的任务很耗时,会影响到其他定时任务的执行,因为s
1、springboot整合quartz执行多个定时任务时报:org.quartz.ObjectAlreadyExistsException:Unabletos