blocks|key|146365|text|您可以使用Trigger动态设置下一次执行时间。|type|unstyled|depth|inlineStyleRanges|offset|length|style|CODE|entityRanges|data|146366|有关详细信息，请参阅my+answer+to+Scheduling+a+job+with+Spring+programmatically。|146367|entityMap|0|LINK|mutability|MUTABLE|url|https://stackoverflow.com/questions/14630539/scheduling-a-job-with-spring-programmatically-with-fixedrate-set-dynamically/14632758|1|https://stackoverflow.com/questions/14630539/scheduling-a-job-with-spring-programmatically-with-fixedrate-set-dynamically^0|5|7|0|A|9|0|N|19|1|0^^$0|@$1|2|3|4|5|6|7|R|8|@$9|S|A|T|B|C]]|D|@]|E|$]]|$1|F|3|G|5|6|7|U|8|@]|D|@$9|V|A|W|1|X]|$9|Y|A|Z|1|10]]|E|$]]|$1|H|3|-4|5|6|7|11|8|@]|D|@]|E|$]]]|I|$J|$5|K|L|M|E|$N|O]]|P|$5|K|L|M|E|$N|Q]]]]

You can use a <code>Trigger</code> to dynamically set the next execution time.
See <a href="https://stackoverflow.com/questions/14630539/scheduling-a-job-with-spring-programmatically-with-fixedrate-set-dynamically/14632758">my answer</a> to <a href="https://stackoverflow.com/questions/14630539/scheduling-a-job-with-spring-programmatically-with-fixedrate-set-dynamically">Scheduling a job with Spring programmatically</a> for details.

blocks|key|146425|text|创建接口，类似于：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|146426|++++public+abstract+class+DynamicSchedule{
++++++++/**
+++++++++*+Delays+scheduler
+++++++++*+@param+milliseconds+-+the+time+to+delay+scheduler.
+++++++++*/
++++++++abstract+void+delay(Long+milliseconds);

++++++++/**
+++++++++*+Decreases+delay+period
+++++++++*+@param+milliseconds+-+the+time+to+decrease+delay+period.
+++++++++*/
++++++++abstract+void+decreaseDelayInterval(Long+milliseconds);

++++++++/**
+++++++++*+Increases+delay+period
+++++++++*+@param+milliseconds+-+the+time+to+increase+dela+period
++++++++*/
++++++++abstract+void+increaseDelayInterval(Long+milliseconds);
}|code-block|syntax|javascript|146427|接下来，让我们在spring-context项目中实现位于org.springframework.scheduling的触发器接口。|146428|import+org.springframework.scheduling.TaskScheduler;
import+org.springframework.scheduling.Trigger;
import+org.springframework.scheduling.TriggerContext;

import+java.util.Date;
import+java.util.concurrent.ScheduledFuture;

public+class+CustomDynamicSchedule+extends+DynamicSchedule+implements+Trigger+{

++++private+TaskScheduler+taskScheduler;
++++private+ScheduledFuture<?>+schedulerFuture;

++++/**
+++++*+milliseconds
+++++*/
++++private+long+delayInterval;

++++public+CustomDynamicSchedule(TaskScheduler+taskScheduler)+{
++++++++this.taskScheduler+=+taskScheduler;
++++}


++++@Override
++++public+void+increaseDelayInterval(Long+delay)+{
++++++++if+(schedulerFuture+!=+null)+{
++++++++++++schedulerFuture.cancel(true);
++++++++}
++++++++this.delayInterval+%2B=+delay;
++++++++schedulerFuture+=+taskScheduler.schedule(()+->+{+},+this);
++++}

++++@Override
++++public+void+decreaseDelayInterval(Long+delay)+{
++++++++if+(schedulerFuture+!=+null)+{
++++++++++++schedulerFuture.cancel(true);
++++++++}
++++++++this.delayInterval+-=+delay;
++++++++schedulerFuture+=+taskScheduler.schedule(()+->+{+},+this);
++++}

++++@Override
++++public+void+delay(Long+delay)+{
++++++++if+(schedulerFuture+!=+null)+{
++++++++++++schedulerFuture.cancel(true);
++++++++}
++++++++this.delayInterval+=+delay;
++++++++schedulerFuture+=+taskScheduler.schedule(()+->+{+},+this);
++++}

++++@Override
++++public+Date+nextExecutionTime(TriggerContext+triggerContext)+{
++++++++Date+lastTime+=+triggerContext.lastActualExecutionTime();
++++++++return+(lastTime+==+null)+?+new+Date()+:+new+Date(lastTime.getTime()+%2B+delayInterval);
++++}
}|146429|现在配置：|146430|@Configuration
public+class+DynamicSchedulerConfig+{
++++@Bean
++++public+CustomDynamicSchedule+getDynamicScheduler()+{
++++++++ThreadPoolTaskScheduler+threadPoolTaskScheduler+=+new+ThreadPoolTaskScheduler();
++++++++threadPoolTaskScheduler.initialize();
++++++++return++new+CustomDynamicSchedule(threadPoolTaskScheduler);
++++}
}|146431|和用法：|146432|@EnableScheduling
@Component
public+class+TestSchedulerComponent+{

++++@Autowired
++++private+CustomDynamicSchedule+dynamicSchedule;

++++@Scheduled(fixedDelay+=+5000)
++++public+void+testMethod()+{
++++++++dynamicSchedule.delay(1000l);
++++++++dynamicSchedule.increaseDelayInterval(9000l);
++++++++dynamicSchedule.decreaseDelayInterval(5000l);
++++}

}|146433|entityMap^0|0|0|0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|U|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|V|8|@]|9|@]|A|$E|F]]|$1|G|3|H|5|6|7|W|8|@]|9|@]|A|$]]|$1|I|3|J|5|D|7|X|8|@]|9|@]|A|$E|F]]|$1|K|3|L|5|6|7|Y|8|@]|9|@]|A|$]]|$1|M|3|N|5|D|7|Z|8|@]|9|@]|A|$E|F]]|$1|O|3|P|5|6|7|10|8|@]|9|@]|A|$]]|$1|Q|3|R|5|D|7|11|8|@]|9|@]|A|$E|F]]|$1|S|3|-4|5|6|7|12|8|@]|9|@]|A|$]]]|T|$]]

create interface , something like that:

<pre><code> public abstract class DynamicSchedule{
 /**
 * Delays scheduler
 * @param milliseconds - the time to delay scheduler.
 */
 abstract void delay(Long milliseconds);

 /**
 * Decreases delay period
 * @param milliseconds - the time to decrease delay period.
 */
 abstract void decreaseDelayInterval(Long milliseconds);

 /**
 * Increases delay period
 * @param milliseconds - the time to increase dela period
 */
 abstract void increaseDelayInterval(Long milliseconds);
}
</code></pre>

Next, lets implement Trigger interface that is located at org.springframework.scheduling in the spring-context project.

<pre><code>import org.springframework.scheduling.TaskScheduler;
import org.springframework.scheduling.Trigger;
import org.springframework.scheduling.TriggerContext;

import java.util.Date;
import java.util.concurrent.ScheduledFuture;

public class CustomDynamicSchedule extends DynamicSchedule implements Trigger {

 private TaskScheduler taskScheduler;
 private ScheduledFuture&lt;?&gt; schedulerFuture;

 /**
 * milliseconds
 */
 private long delayInterval;

 public CustomDynamicSchedule(TaskScheduler taskScheduler) {
 this.taskScheduler = taskScheduler;
 }


 @Override
 public void increaseDelayInterval(Long delay) {
 if (schedulerFuture != null) {
 schedulerFuture.cancel(true);
 }
 this.delayInterval += delay;
 schedulerFuture = taskScheduler.schedule(() -&gt; { }, this);
 }

 @Override
 public void decreaseDelayInterval(Long delay) {
 if (schedulerFuture != null) {
 schedulerFuture.cancel(true);
 }
 this.delayInterval -= delay;
 schedulerFuture = taskScheduler.schedule(() -&gt; { }, this);
 }

 @Override
 public void delay(Long delay) {
 if (schedulerFuture != null) {
 schedulerFuture.cancel(true);
 }
 this.delayInterval = delay;
 schedulerFuture = taskScheduler.schedule(() -&gt; { }, this);
 }

 @Override
 public Date nextExecutionTime(TriggerContext triggerContext) {
 Date lastTime = triggerContext.lastActualExecutionTime();
 return (lastTime == null) ? new Date() : new Date(lastTime.getTime() + delayInterval);
 }
}
</code></pre>

now configuration:

<pre><code>@Configuration
public class DynamicSchedulerConfig {
 @Bean
 public CustomDynamicSchedule getDynamicScheduler() {
 ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
 threadPoolTaskScheduler.initialize();
 return new CustomDynamicSchedule(threadPoolTaskScheduler);
 }
}
</code></pre>

and usage:

<pre><code>@EnableScheduling
@Component
public class TestSchedulerComponent {

 @Autowired
 private CustomDynamicSchedule dynamicSchedule;

 @Scheduled(fixedDelay = 5000)
 public void testMethod() {
 dynamicSchedule.delay(1000l);
 dynamicSchedule.increaseDelayInterval(9000l);
 dynamicSchedule.decreaseDelayInterval(5000l);
 }

}
</code></pre>

blocks|key|146502|text|您也可以使用Spring+Expression+Language+(SpEL)来实现这一点。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|146503|@Scheduled(fixedDelayString+=+"#{@applicationPropertyService.getApplicationProperty()}")
public+void+getSchedule(){
+++System.out.println("in+scheduled+job");
}

@Service
public+class+ApplicationPropertyService+{

++++public+String+getApplicationProperty(){
++++++++//get+your+value+here
++++++++return+"5000";
++++}
}|code-block|syntax|javascript|146504|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

You can also use Spring Expression Language (SpEL) for this.

<pre><code>@Scheduled(fixedDelayString = "#{@applicationPropertyService.getApplicationProperty()}")
public void getSchedule(){
 System.out.println("in scheduled job");
}

@Service
public class ApplicationPropertyService {

 public String getApplicationProperty(){
 //get your value here
 return "5000";
 }
}
</code></pre>

I have a requirement to run a batch job at a fixed interval and have the ability to change the time of this batch job at runtime. For this I came across <code>@Scheduled</code> annotation provided under Spring framework. But I'm not sure how I'd change the value of fixedDelay at runtime. I did some googling around but didn't find anything useful.

How to change Spring's @Scheduled fixedDelay at runtime?

翻译质量差，导致语言生硬或混乱。

没有提供实际的解决方法或示例。

解答不清晰，无法理解或解决问题。

页面排版不美观，阅读体验差。

文章

问答

视频

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

我需要以固定的时间间隔运行批处理作业，并且能够在运行时更改此批处理作业的时间。为此，我偶然发现了Spring框架下提供的@Scheduled注释。但我不确定如何在运行时更改fixedDelay的值。我用谷歌搜索了一下，但没有找到任何有用的东西。

问如何在运行时更改Spring的@Scheduled fixedDelay？
EN

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问如何在运行时更改Spring的@Scheduled fixedDelay？EN

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问如何在运行时更改Spring的@Scheduled fixedDelay？
EN