Spring Boot：实现可运行时启停的Cron定时任务（替代@Scheduled）

问题描述 #

在Spring Boot项目中使用@Scheduled注解实现定时任务，代码如下：

@Override
@Scheduled(cron = "#{scanningTime}")
public void execution() {
    invitePlanScanner();
}

但遇到了无法在运行时停止该任务的问题。尝试过放弃注解手动创建Cron任务，但发现Java标准库没有直接提供带停止方法的Cron任务实现，求可行的解决思路。

可行解决方案 #

方案一：使用ScheduledTaskRegistrar动态管理任务 #

通过Spring的ScheduledTaskRegistrar可以手动注册、取消定时任务，完全脱离@Scheduled注解的限制：

@Component
public class DynamicTaskManager {
    private final ScheduledTaskRegistrar taskRegistrar = new ScheduledTaskRegistrar();
    private ScheduledTask currentTask;

    // 启动/切换定时任务
    public void startOrSwitchTask(String cronExpression) {
        // 先停止已有任务
        if (currentTask != null) {
            currentTask.cancel();
        }
        // 创建并注册新的Cron任务
        CronTask cronTask = new CronTask(this::invitePlanScanner, cronExpression);
        currentTask = taskRegistrar.scheduleCronTask(cronTask);
    }

    // 停止定时任务
    public void stopTask() {
        if (currentTask != null) {
            currentTask.cancel();
            currentTask = null;
        }
    }

    // 你的任务逻辑
    private void invitePlanScanner() {
        // 业务代码
    }
}

调用startOrSwitchTask()可以启动或切换任务的Cron表达式，调用stopTask()即可直接停止任务调度。

方案二：基于ThreadPoolTaskScheduler实现动态调度 #

通过Spring提供的ThreadPoolTaskScheduler，可以获取任务的ScheduledFuture引用，进而实现任务的取消：

首先配置调度器Bean：

@Configuration
public class TaskSchedulerConfig {
    @Bean
    public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.setPoolSize(5);
        scheduler.setThreadNamePrefix("dynamic-task-");
        scheduler.initialize();
        return scheduler;
    }
}

然后实现任务管理类：

@Component
public class DynamicTaskService {
    @Autowired
    private ThreadPoolTaskScheduler taskScheduler;
    private ScheduledFuture<?> scheduledFuture;

    // 启动Cron任务
    public void startCronTask(String cron) {
        // 停止已有任务
        if (scheduledFuture != null) {
            scheduledFuture.cancel(true);
        }
        // 调度新任务，传入任务逻辑和Cron触发器
        scheduledFuture = taskScheduler.schedule(this::invitePlanScanner, new CronTrigger(cron));
    }

    // 停止任务
    public void stopTask() {
        if (scheduledFuture != null) {
            // true表示如果任务正在执行，尝试中断线程
            scheduledFuture.cancel(true);
            scheduledFuture = null;
        }
    }

    private void invitePlanScanner() {
        // 业务逻辑
    }
}

方案三：给注解式任务添加执行开关（轻量方案） #

如果不需要完全停止任务调度，只是想临时跳过任务执行，可以添加一个volatile修饰的开关变量：

@Component
public class ScheduledTask {
    // volatile保证多线程下的可见性
    private volatile boolean taskEnabled = true;

    @Scheduled(cron = "#{scanningTime}")
    public void execution() {
        if (!taskEnabled) {
            return;
        }
        invitePlanScanner();
    }

    public void stopTask() {
        taskEnabled = false;
    }

    public void resumeTask() {
        taskEnabled = true;
    }

    private void invitePlanScanner() {
        // 业务逻辑
    }
}

这种方式最简单，但任务本身仍会被Spring定时调度，只是执行逻辑被跳过，适合对资源消耗要求不高的场景。

内容的提问来源于stack exchange，提问作者Thành Đặng