如何在运行时使用春季启用调度注释重新启动计划任务？

java scheduled-tasks spring jobs java-8

2022-09-03 15:30:14

我一直在研究如何使用Java 8和spring在运行时更改作业的频率。这个问题非常有用，但它并没有完全解决我的问题。

我现在可以配置下一步应该执行作业的日期。但是如果将延迟设置为1年，那么我需要等待1年才能考虑新配置。

我的想法是在配置值更改时停止计划任务（从另一个类中更改）。然后在下次应执行任务时重新计算。也许有一种更简单的方法可以做到这一点。

这是我到目前为止的代码。

@Configuration
@EnableScheduling
public class RequestSchedulerConfig implements SchedulingConfigurer {

    @Autowired
    SchedulerConfigService schedulerConfigService;

    @Bean
    public RequestScheduler myBean() {
        return new RequestScheduler();
    }

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

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.setScheduler(taskExecutor());
        taskRegistrar.addTriggerTask(
                new Runnable() {
                    @Override public void run() {
                        myBean().startReplenishmentComputation();
                    }
                },
                new Trigger() {
                    @Override public Date nextExecutionTime(TriggerContext triggerContext) {
                        Duration d = schedulerConfigService.getIntervalFromDB();
                        return DateTime.now().plus(d).toDate();
                    }
                }
        );
    }
}

这就是我想做的。

@RestController
@RequestMapping("/api/config/scheduler")
public class RequestSchedulerController {

    @Autowired
    ApplicationConfigWrapper applicationConfigWrapper;

    @RequestMapping("/set/")
    @ResponseBody
    public String setRequestSchedulerConfig(@RequestParam(value = "frequency", defaultValue = "") final String frequencyInSeconds){
        changeValueInDb(frequencyInSeconds);
        myJob.restart();
        return "Yeah";
    }

}

答案 1

创建一个获取注入的 TaskScheduler 的单例 Bean。这将作为状态变量保存所有 ScheduledFutures，如private ScheduledFuture job1;
部署时，从数据库加载所有计划数据并启动作业，填充所有状态变量，如。job1
在更改调度数据时，取消相应的（例如），然后使用新的调度数据再次启动它。Futurejob1

这里的关键思想是在创建时控制它们，以便将它们保存在一些状态变量中，以便在调度数据中的某些内容更改时，您可以取消它们。Future

以下是工作代码：

应用上下文.xml

<task:annotation-driven />
<task:scheduler id="infScheduler" pool-size="10"/>

单例豆，保持 sFuture

@Component
public class SchedulerServiceImpl implements SchedulerService {

        private static final Logger logger = LoggerFactory.getLogger(SchedulerServiceImpl.class);

        @Autowired
        @Qualifier(value="infScheduler")
        private TaskScheduler taskScheduler;

        @Autowired
        private MyService myService;

        private ScheduledFuture job1;//for other jobs you can add new private state variables

        //Call this on deployment from the ScheduleDataRepository and everytime when schedule data changes.
        @Override
        public synchronized void scheduleJob(int jobNr, long newRate) {//you are free to change/add new scheduling data, but suppose for now you only want to change the rate
                if (jobNr == 1) {//instead of if/else you could use a map with all job data
                        if (job1 != null) {//job was already scheduled, we have to cancel it
                                job1.cancel(true);
                        }
                        //reschedule the same method with a new rate
                        job1 = taskScheduler.scheduleAtFixedRate(new ScheduledMethodRunnable(myService, "methodInMyServiceToReschedule"), newRate);
                }
        }
}

答案 2

使用来获取所有计划任务和呼叫怎么样？或者也许执行并重新创建ThreadPoolTaskScheduler并在SchpendmentdTaskRegistrar中再次设置它？Set<ScheduledTask> ScheduledTaskRegistrar.getScheduledTasks()ScheduledTask::cancel()ThreadPoolTaskScheduler::shutdown()