欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Springboot定時(shí)任務(wù)Scheduled重復(fù)執(zhí)行操作

 更新時(shí)間:2020年09月30日 09:50:51   作者:oO淺色雨Oo  
這篇文章主要介紹了Springboot定時(shí)任務(wù)Scheduled重復(fù)執(zhí)行操作,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧

今天用scheduled寫定時(shí)任務(wù)的時(shí)候發(fā)現(xiàn)定時(shí)任務(wù)一秒重復(fù)執(zhí)行一次,而我的cron表達(dá)式為 * 0/2 * * * * 。

在源碼調(diào)試的過(guò)程中,發(fā)現(xiàn)是我的定時(shí)任務(wù)執(zhí)行過(guò)程太短導(dǎo)致的。

于是我另外寫了個(gè)簡(jiǎn)單的定時(shí)任務(wù)

@Component
public class TestJob {
 @Scheduled(cron = "* 0/2 * * * *")
 public void test() {
 System.out.println("測(cè)試開(kāi)始");
 System.out.println("測(cè)試結(jié)束");
 }
}

上述任務(wù)在啟動(dòng)之后一直執(zhí)行。

然后我在任務(wù)后面加入線程睡眠1分鐘。

@Component
public class TestJob {
 @Scheduled(cron = "* 0/2 * * * *")
 public void test() {
 System.out.println("測(cè)試開(kāi)始");
 System.out.println("測(cè)試結(jié)束");
 try {
  Thread.sleep(60000);
 } catch (InterruptedException e) {
  e.printStackTrace();
 }
 System.out.println("睡眠結(jié)束");
 }
}

上述任務(wù)執(zhí)行一次就沒(méi)有再執(zhí)行了。

所以我繼續(xù)深入查看源碼,發(fā)現(xiàn)問(wèn)題在于CronSequenceGenerator.class的next方法。

public Date next(Date date) {
    Calendar calendar = new GregorianCalendar();
    calendar.setTimeZone(this.timeZone);
    calendar.setTime(date);
   //1.設(shè)置下次執(zhí)行時(shí)間的毫秒為0,如上次任務(wù)執(zhí)行過(guò)程不足1秒,則calendar的時(shí)間會(huì)被設(shè)置成上次任務(wù)的執(zhí)行時(shí)間
    calendar.set(14, 0);
    long originalTimestamp = calendar.getTimeInMillis();
    this.doNext(calendar, calendar.get(1));
   //2.由于有上面一步,執(zhí)行時(shí)間太短,會(huì)導(dǎo)致下述條件為true
    if(calendar.getTimeInMillis() == originalTimestamp) {
   //3.calendar在原來(lái)的時(shí)間上增加1秒
      calendar.add(13, 1);
   //CronSequenceGenerator的doNext算法從指定時(shí)間開(kāi)始(包括指定時(shí)間)查找符合cron表達(dá)式規(guī)則下一個(gè)匹配的時(shí)間
   //注意第一個(gè)匹配符是*,由于增加了1秒,依然符合cron="* 0/2 * * * *",所以下一個(gè)執(zhí)行時(shí)間就是在原來(lái)的基礎(chǔ)上增加了一秒
      this.doNext(calendar, calendar.get(1));
    }
    return calendar.getTime();
  }

請(qǐng)查看代碼中的注釋,由于任務(wù)執(zhí)行時(shí)間太短了,代碼會(huì)進(jìn)入if語(yǔ)句,并設(shè)置執(zhí)行時(shí)間在原來(lái)的基礎(chǔ)上增加一秒。

但由于增加一秒后的時(shí)間戳依然符合cron表達(dá)式,于是在執(zhí)行完代碼后一秒,任務(wù)又開(kāi)始執(zhí)行了。

解決辦法:

程序執(zhí)行時(shí)間太短沒(méi)有關(guān)系,只要cron表達(dá)式秒的匹配符不設(shè)置為*就可以了。

cron表達(dá)式可以設(shè)置為"0 0/2 * * * *",這樣在執(zhí)行到next方法中的doNext方法時(shí)就會(huì)發(fā)現(xiàn)時(shí)間增加1秒不符合cron表達(dá)式了,從而去尋找下一個(gè)合適的執(zhí)行時(shí)間。

補(bǔ)充知識(shí):SpringBoot 定時(shí)器/定時(shí)任務(wù):在一個(gè)指定的周期時(shí)間內(nèi),執(zhí)行某一項(xiàng)任務(wù)。

說(shuō)多都是累,直接上代碼:

實(shí)現(xiàn)方式有三種(可能還有更多的實(shí)現(xiàn),這三種只是樓主目前所知道的):

1、靜態(tài)定時(shí)器,無(wú)法修改周期

@Configuration("myScheduled")
@EnableScheduling
public class ScheduledDemo{
  //每10秒執(zhí)行一次
  @Scheduled(cron="0/10 * * * * ?")
  public void timmer(){
 System.out.println("執(zhí)行任務(wù)");
  }
}  

2、動(dòng)態(tài)定時(shí)器

//通過(guò)setCron 方法修改 任務(wù)周期
@Component("myScheduled")
public class ScheduledDemo implements SchedulingConfigurer{
 //默認(rèn)的任務(wù)周期為 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("執(zhí)行任務(wù)");
  }
  
 }, new Trigger() {
  @Override
  public Date nextExecutionTime(TriggerContext triggerContext) {
  return new CronTrigger(cron).nextExecutionTime(triggerContext);
  }
 });
 }
 
 public void setCron(String cron) {
 this.cron = cron;
 }
}

3、動(dòng)態(tài)定時(shí)器:多線程定時(shí)任務(wù)執(zhí)行,可以設(shè)置執(zhí)行線程池?cái)?shù)(默認(rèn)一個(gè)線程)

@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("執(zhí)行任務(wù)");
  }
 }, 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 的參數(shù)說(shuō)明,詳細(xì)說(shuō)明直接網(wǎng)上搜吧!

大概說(shuō)明:秒 分 時(shí) 日 月 星期 年(可省略)

/ 后面表示周期

- 表示范圍

星期一般用 ? ,為了防止和 日 混淆,如果星期有值,則日用 ?

“0/10 * * * * ?”表示每10秒

“0 0/10 * * * ?”表示每10分

以上這篇Springboot定時(shí)任務(wù)Scheduled重復(fù)執(zhí)行操作就是小編分享給大家的全部?jī)?nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。

相關(guān)文章

  • JPA中@JoinColumn的name和referencedColumnName屬性的區(qū)別及說(shuō)明

    JPA中@JoinColumn的name和referencedColumnName屬性的區(qū)別及說(shuō)明

    這篇文章主要介紹了JPA中@JoinColumn的name和referencedColumnName屬性的區(qū)別及說(shuō)明,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2024-05-05
  • 自定義log4j.properties的加載位置方式

    自定義log4j.properties的加載位置方式

    這篇文章主要介紹了自定義log4j.properties的加載位置方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2021-12-12
  • 最新評(píng)論