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重复执行操作就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持我们。

(0)

相关推荐

  • springboot 定时任务@Scheduled实现解析

    这篇文章主要介绍了springboot 定时任务@Scheduled实现解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 1.pom.xml中导入必要的依赖: <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version&g

  • SpringBoot执行定时任务@Scheduled的方法

    在做项目时,需要一个定时任务来接收数据存入数据库,后端再写一个接口来提供该该数据的最新的那一条. 数据保持最新:设计字段sign的值(0,1)来设定是否最新 定时任务插入数据:首先进行更新,将所有为1即新数据设置过期,然后插入新数据,设置sign为1.这两个操作是原子操作.通过添加事务来进行控制. Java 定时任务的几种实现方式 基于 java.util.Timer 定时器,实现类似闹钟的定时任务 使用 Quartz.elastic-job.xxl-job 等开源第三方定时任务框架,适合分布式

  • SpringBoot中使用@Scheduled注解创建定时任务的实现

    在项目日常开发过程中,经常需要定时任务来帮我们做一些工作,如清理日志.定时任务的实现方法主要有 Timer.Quartz 以及 elastic-job Timer 实现定时任务 只执行一次的定时任务 Timer timer = new Timer(); timer.schedule(new TimerTask() { @Override public void run() { System.out.println("2000毫米后执行一次."); } }, 2000); timer.s

  • 详解SpringBoot开发案例之整合定时任务(Scheduled)

    来来来小伙伴们,基于上篇的邮件服务,定时任务就不单独分项目了,天然整合进了邮件服务中. 不知道,大家在工作之中,经常会用到那些定时任务去执行特定的业务,这里列举一下我在工作中曾经使用到的几种实现. 任务介绍 Java自带的java.util.Timer类,这个类允许你调度一个java.util.TimerTask任务.Timer的优点在于简单易用:缺点是Timer的所有任务都是由同一个线程调度的,因此所有任务都是串行执行的.同一时间只能有一个任务在执行,前一个任务的延迟或异常都将会影响到之后的任

  • Springboot通过Scheduled实现定时任务代码

    定时任务一般会存在中大型企业级项目中,为了减少服务器.数据库的压力往往会采用时间段性的去完成某些业务逻辑.比较常见的就是金融服务系统推送回调,一般支付系统订单在没有收到成功的回调返回内容时会持续性的回调,这种回调一般都是定时任务来完成的.还有就是报表的生成,我们一般会在客户访问量过小的时候来完成这个操作,那往往都是在凌晨.这时我们也可以采用定时任务来完成逻辑.SpringBoot为我们内置了定时任务,我们只需要一个注解就可以开启定时为我们所用了. 在开发中,定时任务是常见的功能,在spring

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

    今天用scheduled写定时任务的时候发现定时任务一秒重复执行一次,而我的cron表达式为 * 0/2 * * * * . 在源码调试的过程中,发现是我的定时任务执行过程太短导致的. 于是我另外写了个简单的定时任务 @Component public class TestJob { @Scheduled(cron = "* 0/2 * * * *") public void test() { System.out.println("测试开始"); System.o

  • springboot定时任务@Scheduled执行多次的问题

    目录 springboot定时任务@Scheduled执行多次 原因 解决方法 使用 @Scheduled 定时任务突然不执行了 springboot定时任务@Scheduled执行多次 在spring boot开发定时任务时遇到一个很怪异的现象..我进行调试模式,在没有bug的情况下.执行了三 次才停止..如图: 原因 是因为执行时间太短,在CronSequenceGenerator.class的next方法. public Date next(Date date) { Calendar ca

  • spring-boot通过@Scheduled配置定时任务及定时任务@Scheduled注解的方法

    串行的定时任务 @Component public class ScheduledTimer { private Logger logger = Logger.getLogger(this.getClass()); /** * 定时任务,1分钟执行1次,更新潜在客户超时客户共享状态 */ @Scheduled(cron="0 0/1 8-20 * * ?") public void executeUpdateCuTask() { Thread current = Thread.curr

  • Spring Task定时任务每天零点执行一次的操作

    最近根据项目的需求,需要限制用户每天的发送短信数量.这样以来就需要写一个定时任务,每天去置零一次所有用户的发送短信统计数量. 首先,在application.xml文件中添加 <task:annotation-driven /> 接着就是编写自己的业务处理逻辑 package com.*.*.service; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.sch

  • java使用@Scheduled注解执行定时任务

    前言 在写项目的时候经常需要特定的时间做一些特定的操作,尤其是游戏服务器,维护线程之类的,这时候就需要用到定时器. 如果此时你刚好用的是spring的话,哪么@Scheduled注解是非常好用的. 使用spring @Scheduled注解执行定时任务: 1,在spring-MVC.xml文件中进行配置 2,直接在代码控制层使用即可 package xkhd.game.fix; import org.springframework.beans.factory.annotation.Autowir

  • 解决SpringBoot中的Scheduled单线程执行问题

    目录 问题描述 原因分析: 解决方案: 补充: 问题描述 在一次SpringBoot中使用Scheduled定时任务时,发现某一个任务出现执行占用大量资源,会导致其他任务也执行失败.类似于以下模拟场景,test1定时任务模拟有五秒钟执行时间,这时会同步影响到test2任务的执行,导致test2任务也变成五秒执行一次. @Scheduled(fixedRate = 1000) public void test1() throws InterruptedException { log.info(Th

  • Spring多定时任务@Scheduled执行阻塞问题解决

    目录 一. 问题描述 二. 场景复现 三. 解决方案 方案一:使用@Async注解实现异步任务 方案二:手动设置定时任务的线程池大小 四. 总结 一. 问题描述 最近项目中发现一个问题,计划每日凌晨4:40执行一个定时任务,使用注解方式: @Scheduled(cron = “0 40 4 * * ?”),cron表达式明显没有问题,但是这个定时任务总是不按时执行,有时候得等到8点多,有时候9点多才执行.后来查了下,原来这种定时方式默认是单线程执行的,恰好我这里有多个定时任务,并且其中有个在4:

随机推荐