SpringBoot定时任务Scheduled动态修改Cron执行时间

场景

当某些简单的定时任务需要通过后台修改执行时间时，通过spring boot自带的定时任务来实现是个不错的选择。

代码实现

创建定时任务类

需要实现SchedulingConfigurer接口

@Slf4j
@Component
@Configuration
public class Scheduled implements SchedulingConfigurer{

    private String cron;
    TaskScheduler taskScheduler;
	@Autowired
	CronMapper cronMapper;

    @Bean
    public TaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.setPoolSize(30);
        scheduler.setThreadNamePrefix("TaskScheduler-");
        scheduler.initialize();
        return scheduler;
    }

	@Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
		this.taskRegistrar=taskRegistrar;
		this.taskScheduler=taskScheduler();
		scheduleTask();
    }

	 public void scheduleTask() {
		 taskScheduler.schedule(this.task, triggerContext -> {
             //从数据库获取执行周期
             if(!StringUtils.hasText(this.cron)) {
             	Cron c = cronMapper.selectById("1");
             	//如果为空设置默认
             	if(c==null) {
             		c=new Cron();
                 	c.setCronId("1");
                 	c.setCron("0 0 0/6 * * ? ");
                 	cronMapper.insert(c);
             	}
             	this.cron = c.getCron();
             }
             //返回执行周期
             return new CronTrigger(this.cron).nextExecutionTime(triggerContext);
         });
	 }

    public void setCron(String cron) {
		this.cron = cron;
	}
}

通过接口触发修改执行时间

@PostMapping
public String updateCron(String cron){
	 //此处省略修改数据库中的cron 值 
     ...

     //修改为新的执行时间
     scheduled.setCron(cron);
     scheduled.scheduleTask();
     return "修改成功";
}

• 本文作者： reiner
• 本文链接： https://reiner.host/posts/1230.html
• 版权声明： 转载请注明出处，并附上原文链接