Spring TaskScheduler 本身不支持动态增删改任务，但可通过 ThreadPoolTaskScheduler 返回的 ScheduledFuture 手动注册/取消任务并维护引用；需用 ThreadPoolTaskScheduler 而非 @EnableScheduling，配合 ConcurrentHashMap 存储 future 实现增删改，更新须先取消再重提，持久化可选。
Spring 的 TaskScheduler 本身不直接支持“动态增删改”任务，但可以通过组合 ScheduledTask、TaskScheduler 和自定义管理逻辑来实现动态定时任务。核心思路是：**手动注册/取消任务，并维护任务引用以便后续控制**。
使用 ThreadPoolTaskScheduler 创建可管理的调度器
必须用 ThreadPoolTaskScheduler（而非仅配置 @EnableScheduling），因为它实现了 TaskScheduler 接口并提供 schedule() 方法返回可取消的 ScheduledFuture：
- 在配置类中声明 Bean，启用线程池和优雅关闭：
@Bean
public TaskScheduler taskScheduler() {
ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
scheduler.setPoolSize(5);
scheduler.setThreadNamePrefix("dynamic-task-");
scheduler.setWaitForTasksToCompleteOnShutdown(true);
scheduler.setAwaitTerminationSeconds(60);
return scheduler;
}
- 注入该 Bean，在服务类中用于动态调度
动态添加一次性或周期性任务
调用 schedule() 方法，传入 Runnable 和 Trigger（如 CronTrigger 或 PeriodicTrigger），它会返回 ScheduledFuture —— 这是后续取消任务的唯一凭证：
- 按 Cron 表达式启动任务：
private final Map<String, ScheduledFuture<?>> taskFutures = new ConcurrentHashMap<>();
public void scheduleCronTask(String taskId, String cron, Runnable task) {
CronTrigger trigger = new CronTrigger(cron);
ScheduledFuture<?> future = taskScheduler.schedule(task, trigger);
taskFutures.put(taskId, future);
}
- 按固定延迟启动（如每 30 秒执行一次）：
public void scheduleFixedDelayTask(String taskId, long delayMs, Runnable task) {
PeriodicTrigger trigger = new PeriodicTrigger(delayMs, TimeUnit.MILLISECONDS);
ScheduledFuture<?> future = taskScheduler.schedule(task, trigger);
taskFutures.put(taskId, future);
}
动态取消与更新任务
取消任务只需调用 ScheduledFuture.cancel(true)，并从本地 Map 中移除记录；更新则需先取消旧任务，再提交新任务：
Java项目代码review工具。分析Git变更+完整调用链路上下文，推断业务需求，进行多维度评分和分类汇总，生成完整PRD文档。包含细粒度Java代码审查清单（Null安全、异常处理、Streams、并发、equals/hashCode、资源管理、API设计、性能、MyBatis/ORM、事务边界、SQL/DD...
立即学习“Java免费学习笔记（深入）”；
- 取消指定 ID 的任务：
public boolean cancelTask(String taskId) {
ScheduledFuture<?> future = taskFutures.remove(taskId);
if (future != null) {
return future.cancel(true);
}
return false;
}
- 更新任务（例如修改 Cron 表达式）：
public void updateCronTask(String taskId, String newCron, Runnable newTask) {
cancelTask(taskId); // 先停旧的
scheduleCronTask(taskId, newCron, newTask); // 再启新的
}
注意：不能直接“修改”已提交的任务，必须走“取消 + 重提”流程。
持久化与重启恢复（可选增强）
默认情况下，JVM 停止后所有动态任务丢失。若需开机自动恢复，可将任务配置（ID、cron、参数等）存入数据库或配置中心，并在应用启动时读取并重新调度：
- 监听
ContextRefreshedEvent，加载已启用的任务列表 - 对每条记录调用
scheduleCronTask(...)恢复调度 - 建议加状态字段（如 enabled=true），避免误恢复已停用任务
不复杂但容易忽略。关键不是“有没有 API”，而是管好 ScheduledFuture 的生命周期。
