@Component
public class ScheduledServiceImpl {
    @Scheduled(fixedDelayString = "${eventTracking.delayFixed}")
    private void doTask() {
        Timestamp timestamp = new Timestamp(System.currentTimeMillis());
        System.out.println("current time >>> " + timestamp.toString());
    }
}
 

//定義一個(gè)按時(shí)間執(zhí)行的定時(shí)任務(wù)，在每天16:00執(zhí)行一次。
@Scheduled(cron = "0 0 16 * * ?")
public void depositJob() {
  //執(zhí)行代碼
}
//定義一個(gè)按一定頻率執(zhí)行的定時(shí)任務(wù)，每隔1分鐘執(zhí)行一次
    @Scheduled(fixedRate = 1000 * 60)
    public void job2() {
    //執(zhí)行代碼
}
//定義一個(gè)按一定頻率執(zhí)行的定時(shí)任務(wù)，每隔1分鐘執(zhí)行一次，延遲1秒執(zhí)行
    @Scheduled(fixedRate = 1000 * 60,initialDelay = 1000)
    public void updatePayRecords() {
    //執(zhí)行代碼
}

//說(shuō)明：ScheduledAnnotationBeanPostProcessor繼承BeanPostProcessor。
@Override
public Object postProcessAfterInitialization(final Object bean, String beanName) {
          //省略多個(gè)判斷條件代碼
         for (Map.Entry<Method, Set<Scheduled>> entry : annotatedMethods.entrySet()) {
            Method method = entry.getKey();
            for (Scheduled scheduled : entry.getValue()) {
               processScheduled(scheduled, method, bean);
            }
         }
   }
   return bean;
}

//說(shuō)明：ScheduledAnnotationBeanPostProcessor繼承BeanPostProcessor。
//獲取scheduled類參數(shù)，之后根據(jù)參數(shù)類型、相應(yīng)的延時(shí)時(shí)間、對(duì)應(yīng)的時(shí)區(qū)放入不同的任務(wù)列表中
protected void processScheduled(Scheduled scheduled, Method method, Object bean) {   
     //獲取corn類型
      String cron = scheduled.cron();
      if (StringUtils.hasText(cron)) {
         Assert.isTrue(initialDelay == -1, "'initialDelay' not supported for cron triggers");
         processedSchedule = true;
         String zone = scheduled.zone();
         //放入cron任務(wù)列表中（不執(zhí)行）
         this.registrar.addCronTask(new CronTask(runnable, new CronTrigger(cron, timeZone)));
      }
      //執(zhí)行頻率類型（long類型）
      long fixedRate = scheduled.fixedRate();
      String fixedDelayString = scheduled.fixedDelayString();
      if (fixedRate >= 0) {
         Assert.isTrue(!processedSchedule, errorMessage);
         processedSchedule = true;
          //放入FixedRate任務(wù)列表中（不執(zhí)行）（registrar為ScheduledTaskRegistrar）
         this.registrar.addFixedRateTask(new IntervalTask(runnable, fixedRate, initialDelay));
      }
     //執(zhí)行頻率類型（字符串類型，不接收參數(shù)計(jì)算如：600*20）
      String fixedRateString = scheduled.fixedRateString();
      if (StringUtils.hasText(fixedRateString)) {
         Assert.isTrue(!processedSchedule, errorMessage);
         processedSchedule = true;
         if (this.embeddedValueResolver != null) {
            fixedRateString = this.embeddedValueResolver.resolveStringValue(fixedRateString);
         }
         fixedRate = Long.parseLong(fixedRateString);
         //放入FixedRate任務(wù)列表中（不執(zhí)行）
         this.registrar.addFixedRateTask(new IntervalTask(runnable, fixedRate, initialDelay));
      }
}
   return bean;
}

protected void scheduleTasks() {
   //順序執(zhí)行相應(yīng)的Cron
   if (this.cronTasks != null) {
      for (CronTask task : this.cronTasks) {
         this.scheduledFutures.add(this.taskScheduler.schedule(
               task.getRunnable(), task.getTrigger()));
      }
   }
  //順序執(zhí)行所有的“fixedRate”定時(shí)任務(wù)（無(wú)延遲，也就是說(shuō)initialDelay參數(shù)為空），因?yàn)闊o(wú)延遲，所以定時(shí)任務(wù)會(huì)直接執(zhí)行一次，執(zhí)行任務(wù)完成后，會(huì)將下次執(zhí)行任務(wù)的時(shí)間放入delayedExecute中等待下次執(zhí)行。
   if (this.fixedRateTasks != null) {
      for (IntervalTask task : this.fixedRateTasks) {
         if (task.getInitialDelay() > 0) {
            Date startTime = new Date(now + task.getInitialDelay());
            this.scheduledFutures.add(this.taskScheduler.scheduleAtFixedRate(
                  task.getRunnable(), startTime, task.getInterval()));
         }
         else {
            this.scheduledFutures.add(this.taskScheduler.scheduleAtFixedRate(
                  task.getRunnable(), task.getInterval()));
         }
      }
   }
//順序執(zhí)行所有的“fixedRate”定時(shí)任務(wù)（有延遲，也就是說(shuō)initialDelay參數(shù)不為空）
   if (this.fixedDelayTasks != null) {
      for (IntervalTask task : this.fixedDelayTasks) {
         if (task.getInitialDelay() > 0) {
            Date startTime = new Date(now + task.getInitialDelay());
            this.scheduledFutures.add(this.taskScheduler.scheduleWithFixedDelay(
                  task.getRunnable(), startTime, task.getInterval()));
         }
         else {
            this.scheduledFutures.add(this.taskScheduler.scheduleWithFixedDelay(
                  task.getRunnable(), task.getInterval()));
         }
      }
   }
}

//說(shuō)明：每次執(zhí)行定時(shí)任務(wù)結(jié)束后，會(huì)先設(shè)置下下次定時(shí)任務(wù)的執(zhí)行時(shí)間，以此來(lái)確認(rèn)下次任務(wù)的執(zhí)行時(shí)間。
public void run() {
    boolean periodic = isPeriodic();
    if (!canRunInCurrentRunState(periodic))
        cancel(false);
    else if (!periodic)
        ScheduledFutureTask.super.run();
    else if (ScheduledFutureTask.super.runAndReset()) {
        setNextRunTime();
        reExecutePeriodic(outerTask);
    }
}