Весенняя ботинок - альтернатива расписанию времени.

Question

Я хочу сделать что-то вроде javascript's setInterval(function, interval)/setTimeout(function, timeout) в Spring Boot.

Я нашел @Scheduled аннотацию, которая имеет fixedRate аргумент, но как аннотацию я не могу изменить скорость динамически (или я могу?)

Сейчас я использую java.util.Timer, но я предпочел бы использовать Spring. Есть ли способ?

Могу ли я получить экземпляр Scheduler и работать с ним динамически?

спасибо!

Answer 1

Нашли решение, которое подходит для моего дела.

В Main.java:

@SpringBootApplication 
@ConfigurationProperties 
@EnableScheduling 
public class Main { 
    @Bean 
    ThreadPoolTaskScheduler taskScheduler() { 
     return new ThreadPoolTaskScheduler(); 
    } 

    public static void main(String[] args) { 
     SpringApplication.run(Main.class, args); 
    } 
} 

В службе.java (Вызывается из контроллера отдыха):

@Service 
public class Service { 
    private static final Logger log = LoggerFactory.getLogger(Service.class); 
    private final TaskScheduler scheduler; 

    @Autowired 
    public Service(TaskScheduler scheduler) { 
     this.scheduler = scheduler; 
    } 

    public void startTask(int inteval) { 
     scheduler.schedule(() -> log.info("Doing work"), triggerContext -> { 
      if (some_condition) { 
       ZonedDateTime now = ZonedDateTime.now(); 

       return Date.from(now.plusSeconds(interval).toInstant()); 
      } else { 
       // Stop the execution 
       return null; 
      } 
     }); 
    } 
} 

Это решение работает, но я не уверен, что это правильный путь.

Пожалуйста, можете прокомментировать ниже, и я могу изменить решение, если я получу предложение, которое я нахожу полезным.

Answer 2

Вы можете использовать Trigger, который позволяет динамически контролировать следующее выполнение. Вы должны реализовать SchedulingConfigurer, другой ответ охватывает именно это:

Scheduling a job with Spring programmatically (with fixedRate set dynamically)

EDIT, чтобы ответить на комментарии:

nextExecutionTime называется и дальше и дальше ... В следующий раз, когда задачи (и nextExecutionTime) называются определяется следующим образом:

nextExecutionTime.setTime(lastActualExecutionTime != null ? lastActualExecutionTime : new Date()); 
nextExecutionTime.add(Calendar.MILLISECOND, numberOfMillisecondsBeforeCallingTheTask); 

Все, что вам нужно сделать, это иметь это numberOfMillisecondsBeforeCallingTheTask значение чанга редактор

Пример:

@RestController 
public class MyController { 

    public static int triggerDelay = 1000; 

    @RequestMapping("/changetrigger/{val}") 
    public void test(@PathVariable int val){ 
     this.triggerDelay = val; 
    } 
} 
@SpringBootApplication 
@EnableScheduling 
public class Launcher implements SchedulingConfigurer{ 

    public static void main(String[] args){ 
     new SpringApplicationBuilder() // 
     .sources(Launcher.class)// 
     .run(args); 
    } 

    @Bean(destroyMethod = "shutdown") 
    public Executor taskExecutor() { 
     return Executors.newScheduledThreadPool(100); 
    } 

    @Override 
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { 
     taskRegistrar.setScheduler(taskExecutor()); 
     ; 
     taskRegistrar.addTriggerTask(new TriggerTask(new Runnable() { 
      @Override 
      public void run() { 
       System.out.println("blah"); 
       System.out.println(System.currentTimeMillis()); 
      } 
     }, new Trigger() { 
      @Override 
      public Date nextExecutionTime(TriggerContext triggerContext) { 
       Calendar nextExecutionTime = new GregorianCalendar(); 
       nextExecutionTime.setTime(new Date()); 
       nextExecutionTime.add(Calendar.MILLISECOND, MyController.triggerDelay); 
       System.out.println(System.currentTimeMillis()); 
       return nextExecutionTime.getTime(); 
      }})); 
    } 
} 

Обратите внимание, как динамическое значение MyController.triggerDelay используется для следующего выполнения. Поэтому, если вы измените номер, будет изменено следующее время выполнения. Вы увидите, поставили ли вы точку останова внутри nextExecutionTime.

Answer 3

Вы можете использовать @Scheduled(fixedRateString = "${spring.boot.schedule.rate}") для случая, когда spring.boot.schedule.rate является внешними свойствами в application.properties

spring.boot.schedule.rate = 5000

неправильно понял вопрос, выше только экстернализацию свойства ,

Для динамического решения, может быть, это должно быть работой, используя SPEL в annonation:

@Service 
public class ScheduledService { 
    @Autowired 
    private FixRateProperty fixRateProperty; 

    @Scheduled(fixedRateString = "#{fixRateProperty.fixRate}") 
    private void reportCurrentTime() { 
     System.out.println(new Date());; 
    } 
} 

Это FixRateProperty

@Component 
public class FixRateProperty { 
    private Long fixRate = 500L; 

    public Long getFixRate() { 
     return fixRate; 
    } 

    public void setFixRate(Long fixRate) { 
     this.fixRate = fixRate; 
    } 
} 

так что вы можете экстернализовать скорость в свойствах или установите fixRate.