在Spring Boot中，可以使用@Scheduled注解来创建定时任务，但这种方式不支持动态管理定时任务。要实现定时任务的动态管理，你可以使用ScheduledTaskRegistrar来注册和注销定时任务。
以下是一个简单的例子，展示如何在Spring Boot中动态添加和移除定时任务：
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import org.springframework.scheduling.support.CronTrigger;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
@Configuration
@EnableScheduling
public class DynamicScheduleConfig implements SchedulingConfigurer {
private final ConcurrentMap<String, Runnable> schedules = new ConcurrentHashMap<>();
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
taskRegistrar.setScheduler(Executors.newScheduledThreadPool(5));
schedules.forEach(taskRegistrar::schedule);
}
public void addTask(String taskId, Runnable task, String cronExpression) {
schedules.put(taskId, task);
triggerTask(taskId, cronExpression);
}
public void removeTask(String taskId) {
Runnable task = schedules.remove(taskId);
if (task != null) {
// 停止任务的执行
}
}
public void triggerTask(String taskId, String cronExpression) {
ScheduledTaskRegistrar registrar = new ScheduledTaskRegistrar();
Runnable task = schedules.get(taskId);
if (task != null) {
CronTrigger trigger = new CronTrigger(cronExpression);
registrar.addTriggerTask(task, trigger);
}
// 重新配置ScheduledTaskRegistrar以应用更改
}
}在这个例子中，我们使用了ConcurrentHashMap来存储定时任务，并且提供了添加、移除和触发定时任务的方法。configureTasks方法会在应用启动时加载所有任务，而addTask方法可以动态添加新的任务，removeTask方法可以移除任务，triggerTask方法可以改变任务的触发规则。
请注意，这个例子没有完全实现停止已经执行的任务的逻辑，实际应用中你需要管理正在执行的任务并相应地停止它们。同时，这个例子使用了Executors.newScheduledThreadPool来创建一个新的线程池，你可能需要根据实际情况来管理线程池的生命周期。