Spring Boot配置优雅关闭后仍中断运行中Cron任务求助

我的Spring Boot应用中有多个Cron任务，希望应用关闭前这些任务能执行完毕，但尝试了多种配置后，优雅关闭时运行中的任务仍会被中断。

已尝试的配置与代码 #

1. 配置TaskSchedulerCustomizer Bean #

试图通过自定义Bean配置默认任务调度器：

@Bean
public TaskSchedulerCustomizer taskSchedulerCustomizer() {
    return taskScheduler -> {
        taskScheduler.setPoolSize(CORE_THREAD_POOL_SIZE);
        taskScheduler.setThreadNamePrefix("CronJob-");
        taskScheduler.setWaitForTasksToCompleteOnShutdown(true);
        taskScheduler.setAwaitTerminationSeconds(AWAIT_TERMINATION_SECONDS);
    };
}

2. 添加application.properties配置 #

补充了调度和执行相关的优雅关闭配置：

spring.task.scheduling.shutdown.await-termination=true
spring.task.scheduling.shutdown.await-termination-period=30s
spring.task.execution.shutdown.await-termination=true
spring.task.execution.shutdown.await-termination-period=30s

3. 手动调用initialize() #

在配置完等待属性后尝试调用taskScheduler.initialize()，但无效果。

测试用Cron任务 #

用于复现问题的测试任务：

@Scheduled(cron = "* * * * * *")
public void schedule() throws InterruptedException {
    log.info("starting dummy scheduler");

    Thread.sleep(10000);
    log.info("ending dummy scheduler");
}

可行解决方案 #

方案一：自定义ThreadPoolTaskScheduler Bean #

直接创建并注册自定义的任务调度器Bean，替代Spring默认实现，确保配置的属性完全生效：

@Bean
public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
    ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
    scheduler.setPoolSize(CORE_THREAD_POOL_SIZE);
    scheduler.setThreadNamePrefix("CronJob-");
    scheduler.setWaitForTasksToCompleteOnShutdown(true);
    scheduler.setAwaitTerminationSeconds(AWAIT_TERMINATION_SECONDS);
    scheduler.initialize(); // 自定义Bean需手动初始化
    return scheduler;
}

这种方式绕过了TaskSchedulerCustomizer的间接配置，直接控制调度器实例，避免配置不生效的问题。

方案二：确保任务正确处理中断信号 #

即使调度器配置了等待任务完成，如果任务收到中断信号后直接终止，也无法完成执行。需要在任务中捕获中断异常并处理收尾逻辑：

@Scheduled(cron = "* * * * * *")
public void schedule() {
    log.info("starting dummy scheduler");
    try {
        // 模拟长任务，分阶段检查中断状态
        for (int i = 0; i < 10; i++) {
            if (Thread.currentThread().isInterrupted()) {
                log.info("任务被中断，执行收尾操作");
                // 添加必要的收尾逻辑（如保存数据、释放资源）
                break;
            }
            Thread.sleep(1000);
        }
    } catch (InterruptedException e) {
        log.info("任务收到中断信号，开始收尾");
        // 执行收尾工作
        Thread.currentThread().interrupt(); // 保留线程中断状态
    }
    log.info("ending dummy scheduler");
}

方案三：检查Spring Boot版本兼容性 #

确认使用的Spring Boot版本是否支持spring.task.scheduling.shutdown.*配置项，该配置从Spring Boot 2.3版本开始引入。如果使用更早版本，需升级版本或采用自定义调度器的方式。

内容的提问来源于stack exchange，提问作者Maurice