spring @schedule注解如何动态配置时间间隔

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.scheduling.Trigger;

import org.springframework.scheduling.TriggerContext;

import org.springframework.scheduling.annotation.EnableScheduling;

import org.springframework.scheduling.annotation.SchedulingConfigurer;

import org.springframework.scheduling.config.ScheduledTaskRegistrar;

import org.springframework.scheduling.support.PeriodicTrigger;

import org.springframework.stereotype.Component;

import java.util.Date;

@Component

@EnableScheduling

public class DynamicScheduleTaskSecond implements SchedulingConfigurer {

     private static final long WEEK_MILLIS = 604800000 ;

     private static final long MIN_MILLIS = 1000 ;

     private static long period = 1000 ;

     static long l = System.currentTimeMillis();

     @Autowired

     SetPeriod setPeriod;

     public static long getPeriod() {

         return period;

     }

     public static void setPeriod( long period) {

         DynamicScheduleTaskSecond.period = period;

     }

     @Override

     public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {

         taskRegistrar.addTriggerTask( new Runnable() {

             @Override

             public void run() {

                 try {

                     setPeriod.update(period);

                     System.out.println( "abc" );

                     Long last = System.currentTimeMillis() - l;

                     l = System.currentTimeMillis();

                     System.out.println(last);

                 } catch (Exception e) {

                     e.printStackTrace();

                 }

             }

         }, new Trigger() {

             @Override

             public Date nextExecutionTime(TriggerContext triggerContext) {

                 if (period < MIN_MILLIS || period > WEEK_MILLIS)

                     period = MIN_MILLIS;

                 PeriodicTrigger periodicTrigger = new PeriodicTrigger(period);

                 Date nextExecDate = periodicTrigger.nextExecutionTime(triggerContext);

                 return nextExecDate;

             }

         });

     }

}

import org.springframework.stereotype.Component;

@Component

public class SetPeriod {

     private static Long maxPeriod = 1000l;

     public void update(Long period) {

         maxPeriod += 1000 ;

         setScheduleConfig(maxPeriod);

     }

     public boolean setScheduleConfig(Long period) {

         DynamicScheduleTaskSecond.setPeriod(period);

         return true ;

     }

}

@FunctionalInterface

public interface SchedulingConfigurer {

  /**

   * Callback allowing a {@link org.springframework.scheduling.TaskScheduler

   * TaskScheduler} and specific {@link org.springframework.scheduling.config.Task Task}

   * instances to be registered against the given the {@link ScheduledTaskRegistrar}.

   * @param taskRegistrar the registrar to be configured.

   */

  void configureTasks(ScheduledTaskRegistrar taskRegistrar);

}

public void addTriggerTask(Runnable task, Trigger trigger) {

     this .addTriggerTask( new TriggerTask(task, trigger));

}

public interface Trigger {

     @Nullable

     Date nextExecutionTime(TriggerContext var1);

}

@Component

public class ScheduledTasks {

     @Autowired

     private ActivityService activityService;

//    1000即1s

     @Scheduled (fixedRate = 1000 )

     public void reportCurrentTime() {

         System.out.println( "当前时间: " + DateUtil.getNow());

         log.info( "打印当前时间: {}." , DateUtil.getNow());

     }

     /*每天四点更新一次*/

     @Scheduled (cron = "0 0 4 * * ? " )

     public void updateRankLIstToRedis() {

         /* redis超时设置 expire多次设置会覆盖 */

         List<RankInfoDTO> list = activityService.countRankList(ACTIVITY_WEB);

     }

}