Spring框架下可配置的定时任务实现

package com.example.timer;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;

/**
 * 配置类用于初始化定时任务调度器。
 * @author Example Author
 * @date 2023-09-15
 */
@Configuration
@EnableAsync
public class TimerConfig implements WebMvcConfigurer {
	@Bean
	public TaskScheduler taskScheduler() {
		ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
		scheduler.setPoolSize(10);
		scheduler.setThreadNamePrefix("custom-timer-thread-");
		return scheduler;
	}
}

package com.example.timer.scheduler;

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

import javax.annotation.PostConstruct;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.scheduling.Trigger;
import org.springframework.scheduling.TriggerContext;
import org.springframework.scheduling.support.CronTrigger;
import org.springframework.stereotype.Component;

import com.example.timer.service.TimerService;

/**
 * 动态定时任务示例，展示如何根据Cron表达式动态调整定时任务的执行时间。
 * @author Example Author
 * @date 2023-09-15
 */
@Component
public class DynamicCronTask {
	@Autowired
	private TaskScheduler taskScheduler;
	private ScheduledFuture scheduledFuture;

	/**
	 * 在Spring容器启动后自动调用此方法以启动定时任务。
	 */
	@PostConstruct
	public void init() {
		startTask("0/10 * * * * ?"); // 每10秒执行一次
	}

	/**
	 * 启动定时任务
	 * @param cronExpression 定时任务的Cron表达式
	 */
	public void startTask(String cronExpression) {
		if (scheduledFuture != null) {
			scheduledFuture.cancel(true);
		}
		ScheduledFuture future = taskScheduler.schedule(() -> {
			System.out.println("Executing the task at " + new Date());
			// 这里可以添加具体的业务逻辑
		}, new Trigger() {
			@Override
			public Date nextExecutionTime(TriggerContext triggerContext) {
				CronTrigger crOnTrigger= new CronTrigger(cronExpression);
				return cronTrigger.nextExecutionTime(triggerContext);
			}
		});
		scheduledFuture = future;
	}

	/**
	 * 停止当前正在运行的定时任务。
	 */
	public void stopTask() {
		if (scheduledFuture != null) {
			scheduledFuture.cancel(true);
		}
	}
}