Spring提供了@Scheduled注解用于定時(shí)任務(wù)。

一、@Scheduled的基本使用

啟用調(diào)度支持：@EnableScheduling

可以將@Scheduled注釋與觸發(fā)器元數(shù)據(jù)一起添加到方法中。例如，以下方法每隔5秒調(diào)用一次，并具有固定的延遲，這意味著周期是從前面每次調(diào)用的完成時(shí)間開始計(jì)算的

@Scheduled(fixedDelay=5000)
public void doSomething() {
// something that should execute periodically
}

如果需要固定速率執(zhí)行，可以更改批注中指定的屬性名。以下方法每5秒調(diào)用一次（在每次調(diào)用的連續(xù)開始時(shí)間之間計(jì)算）

@Scheduled(fixedRate=5000)
public void doSomething() {
// something that should execute periodically
}

對(duì)于固定延遲和固定速率任務(wù)，可以通過(guò)指示在首次執(zhí)行方法之前要等待的毫秒數(shù)來(lái)指定初始延遲

@Scheduled(initialDelay=1000, fixedRate=5000)
public void doSomething() {
// something that should execute periodically
}

如果簡(jiǎn)單的周期性調(diào)度不夠表達(dá)，可以提供cron表達(dá)式。例如，以下命令僅在工作日?qǐng)?zhí)行：

@Scheduled(cron="*/5 * * * * MON-FRI")
public void doSomething() {
// something that should execute on weekdays only
}

實(shí)現(xiàn)SchedulingConfigurer接口，重寫configureTasks方法：

@Schedule注解的一個(gè)缺點(diǎn)就是其定時(shí)時(shí)間不能動(dòng)態(tài)更改，它適用于具有固定任務(wù)周期的任務(wù)，若要修改任務(wù)執(zhí)行周期，只能走“停服務(wù)→修改任務(wù)執(zhí)行周期→重啟服務(wù)”這條路。而基于 SchedulingConfigurer 接口方式可以做到。SchedulingConfigurer 接口可以實(shí)現(xiàn)在@Configuration等注解類上。

ScheduledTaskRegistrar類包括以下幾個(gè)重要方法：

void addTriggerTask(Runnable task, Trigger trigger)
void addTriggerTask(TriggerTask task)
void addCronTask(Runnable task, String expression)
void addCronTask(CronTask task)
void addFixedRateTask(Runnable task, long interval)
void addFixedRateTask(IntervalTask task)
void addFixedDelayTask(Runnable task, long delay)
void addFixedDelayTask(IntervalTask task)

具體實(shí)現(xiàn)參考如下：

@Component
public class TestTask implements SchedulingConfigurer {
 
  @Override
  public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
    taskRegistrar.addTriggerTask(new Runnable() {
      @Override
      public void run() {
        // 定時(shí)任務(wù)要執(zhí)行的內(nèi)容
        System.out.println("【開始執(zhí)行定時(shí)任務(wù)。。。】");
      }
    }, new Trigger() {
      @Override
      public Date nextExecutionTime(TriggerContext triggerContext) {
        // 定時(shí)任務(wù)觸發(fā)，可修改定時(shí)任務(wù)的執(zhí)行周期
        String cron = "0 0/5 * * * ?"; //可以將表達(dá)式配置在數(shù)據(jù)庫(kù)中
        CronTrigger trigger = new CronTrigger(cron);
        Date nextExecDate = trigger.nextExecutionTime(triggerContext);
        return nextExecDate;
      }
    });
  }
}

提示：如果在數(shù)據(jù)庫(kù)修改時(shí)格式出現(xiàn)錯(cuò)誤，則定時(shí)任務(wù)會(huì)停止，即使重新修改正確；此時(shí)只能重新啟動(dòng)項(xiàng)目才能恢復(fù)。

二、使用@Scheduled注意事項(xiàng)

• spring的注解@Scheduled 需要寫在實(shí)現(xiàn)方法上；
• 定時(shí)器的任務(wù)方法不能有返回值（如果有返回值，spring初始化的時(shí)候會(huì)告訴你有個(gè)錯(cuò)誤、需要設(shè)定一個(gè)proxytargetclass的某個(gè)值為true），不能指向任何的參數(shù)；
• 如果該方法需要與應(yīng)用程序上下文的其他對(duì)象進(jìn)行交互，通常是通過(guò)依賴注入來(lái)實(shí)現(xiàn)；
• 實(shí)現(xiàn)類上要有組件的注解@Component。

三、使用@Scheduled常見問(wèn)題

單線程任務(wù)丟失，轉(zhuǎn)為異步線程池

默認(rèn)的 ConcurrentTaskScheduler 計(jì)劃執(zhí)行器采用Executors.newSingleThreadScheduledExecutor() 實(shí)現(xiàn)單線程的執(zhí)行器。因此，對(duì)同一個(gè)調(diào)度任務(wù)的執(zhí)行總是同一個(gè)線程。如果任務(wù)的執(zhí)行時(shí)間超過(guò)該任務(wù)的下一次執(zhí)行時(shí)間，則會(huì)出現(xiàn)任務(wù)丟失，跳過(guò)該段時(shí)間的任務(wù)。上述問(wèn)題有以下解決辦法：

采用異步的方式執(zhí)行調(diào)度任務(wù)，配置 Spring 的 @EnableAsync，在執(zhí)行定時(shí)任務(wù)的方法上標(biāo)注 @Async配置任務(wù)執(zhí)行池，線程池大小 n 的數(shù)量為 單個(gè)任務(wù)執(zhí)行所需時(shí)間 / 任務(wù)執(zhí)行的間隔時(shí)間。如下：

//每30秒執(zhí)行一次
@Async("taskExecutor")
@Scheduled(fixedRate = 1000 * 3)
public void reportCurrentTime(){
  System.out.println ("線程" + Thread.currentThread().getName() + "開始執(zhí)行定時(shí)任務(wù)===&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&7&&&====》"
      + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
  long start = System.currentTimeMillis();
}

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

最新評(píng)論