Springboot定时任务Scheduled重复执行操作

Springboot定时任务Scheduled重复执行操作

今天用scheduled写定时任务的时候发现定时任务一秒重复执行一次，而我的cron表达式为 * 0/2 * * * * 。

在源码调试的过程中，发现是我的定时任务执行过程太短导致的。

于是我另外写了个简单的定时任务

@Component

public class TestJob {

@Scheduled(cron = "* 0/2 * * * *")

public void test() {

System.out.println("测试开始");

System.out.println("测试结束");

}

}

上述任务在启动之后一直执行。

然后我在任务后面加入线程睡眠1分钟。

@Component

public 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.由于有上面一步，执行时间太短，会导致下述条件为trmBkwHiYATue

if(calendar.getTimeInMillis() == originalTimestamp) {

//3.calendar在原来的时间上增加1秒

calendar.add(13, 1);

//CronSequenceGenerator的doNext算法从指定时间开始(包括指定时间)查找符合cron表达式规则下一mBkwHiYAT个匹配的时间

//注意第一个匹配符是*，由于增加了1秒，依然符合cron="* 0/2 * * * *"，所以下一个执行时间就是在原来的基础上增加了一秒

this.doNext(calendar, calendar.get(1));

}

return calendar.getTime();

}

请查看代码中的注释，由于任务执行时间太短了，代码会进入if语句，并设置执行时mBkwHiYAT间在原来的基础上增加一秒。

但由于增加一秒后的时间戳依然符合cron表达式，于是在执行完代码后一秒，任务又开始执行了。

解决办法：

程序执行时间太短没有关系，只要cron表达式秒的匹配符不设置为*就可以了。

cron表达式可以设置为"0 0/2 * * * *"，这样在执行到next方法中的doNext方法时就会发现时间增加1秒不符合cron表达式了，从而去寻找下一个合适的执行时间。

补充知识：SpringBoot 定时器/定时任务：在一个指定的周期时间内，执行某一项任务。

说多都是累，直接上代码：

实现方式有三种(可能还有更多的实现，这三种只是楼主目前所知道的)：

1、静态定时器，无法修改周期

@Configuration("myScheduled")

@EnableScheduling

public 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分

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。