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

 更新时间:2020年09月30日 09:50:51   作者:oO浅色雨Oo  
这篇文章主要介绍了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.由于有上面一步,执行时间太短,会导致下述条件为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")
@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分

以上这篇Springboot定时任务Scheduled重复执行操作就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • springmvc+shiro+maven 实现登录认证与权限授权管理

    springmvc+shiro+maven 实现登录认证与权限授权管理

    Shiro 是一个 Apache 下的一开源项目项目,旨在简化身份验证和授权,下面通过实例代码给大家分享springmvc+shiro+maven 实现登录认证与权限授权管理,感兴趣的朋友一起看看吧
    2017-09-09
  • SpringBoot集成SpirePDF实现文本替换功能

    SpringBoot集成SpirePDF实现文本替换功能

    SpirePDF是一个用于.NET平台的高级PDF文档处理库,它提供了一套完整的API,允许开发者创建、编辑、转换、合并、分割和解析PDF文件本文给大家介绍了SpringBoot集成SpirePDF实现文本替换功能,需要的朋友可以参考下
    2024-09-09
  • java 中HashMap、HashSet、TreeMap、TreeSet判断元素相同的几种方法比较

    java 中HashMap、HashSet、TreeMap、TreeSet判断元素相同的几种方法比较

    这篇文章主要介绍了从源码的角度浅析HashMap、TreeMap元素的存储和获取元素的逻辑;从Map与Set之间的关系浅析常用的Set中元素的存储和判断是否重复的逻辑,需要的朋友可以参考下
    2017-01-01
  • Mybatis-plus在项目中的简单应用

    Mybatis-plus在项目中的简单应用

    Mybatis-plus是Spring框架中OOM的一大利器,其简单易用参考官网文档即可很快上手,本文主要介绍了逻辑删除,自动填充,分页插件等的简单使用,感兴趣的可以了解一下
    2021-07-07
  • 利用java反射机制调用类的私有方法(推荐)

    利用java反射机制调用类的私有方法(推荐)

    下面小编就为大家带来一篇利用java反射机制调用类的私有方法(推荐)。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2016-08-08
  • SpringBoot+Mybatis-Plus实现mysql读写分离方案的示例代码

    SpringBoot+Mybatis-Plus实现mysql读写分离方案的示例代码

    这篇文章主要介绍了SpringBoot+Mybatis-Plus实现mysql读写分离方案的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2021-03-03
  • Springboot 集成spring cache缓存的解决方案

    Springboot 集成spring cache缓存的解决方案

    这篇文章主要介绍了Springboot 集成spring cache缓存,使用缓存最关键的一点就是保证缓存与数据库的数据一致性,本文给大家介绍最常用的缓存操作模式,对Springboot 集成spring cache缓存操作流程感兴趣的朋友一起看看吧
    2022-06-06
  • Java学习笔记之面向对象编程精解

    Java学习笔记之面向对象编程精解

    看名字它是注重对象的。当解决一个问题的时候,面向对象会把事物抽象成对象的概念,就是说这个问题里面有哪些对象,然后给对象赋一些属性和方法,然后让每个对象去执行自己的方法,问题得到解决
    2021-09-09
  • JPA中@JoinColumn的name和referencedColumnName属性的区别及说明

    JPA中@JoinColumn的name和referencedColumnName属性的区别及说明

    这篇文章主要介绍了JPA中@JoinColumn的name和referencedColumnName属性的区别及说明,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2024-05-05
  • 自定义log4j.properties的加载位置方式

    自定义log4j.properties的加载位置方式

    这篇文章主要介绍了自定义log4j.properties的加载位置方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-12-12

最新评论