Java动态添加Scheduled的实现方式

@Slf4j
@EnableScheduling
@Configuration
public class SchedulerConfig implements SchedulingConfigurer {
    private final ScheduledTaskRegistrar taskRegistrar;

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

    @Bean
    public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.setPoolSize(Runtime.getRuntime().availableProcessors() / 3 + 1);
        scheduler.setThreadNamePrefix("scheduler-");
        scheduler.setRemoveOnCancelPolicy(true);
        return scheduler;
    }
}

@Autowired
private ScheduledTaskRegistrar taskRegistrar;

public ScheduledTask addCronTask(String cronExpression, Runnable task) {
    CronTask cronTask = new CronTask(task, new CronTrigger(cronExpression));
    return taskRegistrar.scheduleCronTask(cronTask);
}

public void updateCronTask(ScheduledTask oldTask, String newCronExpression, Runnable task) {
    if (oldTask != null) {
        oldTask.cancel(true);
    }
    addCronTask(newCronExpression, task);
}

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class DynamicScheduledTaskExample {
    private static final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);

    public static void main(String[] args) {
        // 添加一个每5秒执行一次的任务
        scheduler.scheduleAtFixedRate(() -> System.out.println("Executing task at fixed rate"), 0, 5, TimeUnit.SECONDS);

        // 模拟一段时间后的动态添加新任务
        try {
            Thread.sleep(10000); // 等待10秒
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        // 添加一个每10秒执行一次的新任务
        scheduler.scheduleAtFixedRate(() -> System.out.println("Executing another task at fixed rate"), 0, 10, TimeUnit.SECONDS);
    }
}

CREATE TABLE IF NOT EXISTS `schedule_setting` (
    `job_id` int NOT NULL AUTO_INCREMENT COMMENT '任务ID',
    `bean_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT 'bean名称',
    `method_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '方法名称',
    `method_params` varchar(8192) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '方法参数',
    `cron_expression` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT 'cron表达式',
    `remark` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '备注',
    `job_status` tinyint(1) DEFAULT NULL COMMENT '状态(1为启用,0为停用)',
    `create_time` datetime DEFAULT NULL COMMENT '创建时间',
    `update_time` datetime DEFAULT NULL COMMENT '修改时间',
    PRIMARY KEY (`job_id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;