Spring Boot测试中@Scheduled Bean在脏上下文重建后持续执行问题

该现象不属于预期行为 #

正常情况下，当Spring上下文被@DirtiesContext标记为脏后，Spring Test框架会主动销毁旧上下文，执行所有单例Bean的销毁生命周期回调，理论上应该关闭所有绑定在旧上下文上的定时任务线程。
你遇到的旧定时任务持续运行的核心原因是定时任务线程泄漏：如果没有显式配置TaskScheduler的销毁逻辑，上下文销毁时调度器的线程池不会被主动关闭，存活的线程还持有旧上下文的Bean引用，就会继续执行旧的定时逻辑，甚至出现多个定时任务并行运行的情况。

可行解决方案 #

方案1：显式配置带销毁逻辑的TaskScheduler #

在项目配置类中自定义TaskScheduler Bean，指定销毁方法，上下文销毁时会自动关闭线程池：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;

@Configuration
public class SchedulerConfig {
    @Bean(destroyMethod = "shutdown")
    public TaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.setPoolSize(5);
        scheduler.setThreadNamePrefix("custom-scheduled-");
        // 配置销毁时等待任务完成的超时时间，可根据业务调整
        scheduler.setAwaitTerminationSeconds(2);
        scheduler.setWaitForTasksToCompleteOnShutdown(true);
        return scheduler;
    }
}

方案2：调整测试类的DirtiesContext策略 #

如果你的测试类下多个用例都会污染上下文，可以在测试类上配置@DirtiesContext的类级策略，确保每个用例执行完后彻底销毁上下文：

import org.springframework.test.annotation.DirtiesContext;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)
public class YourScheduledTaskTest {
    // 测试逻辑
}

方案3：为自定义定时任务实现销毁回调 #

如果你的定时任务是手动注册的，可以在Bean中保存任务的ScheduledFuture引用，销毁时主动取消任务：

import jakarta.annotation.PostConstruct;
import jakarta.annotation.PreDestroy;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.stereotype.Component;
import java.util.concurrent.ScheduledFuture;
import java.time.Duration;

@Component
public class YourEventScanTask {
    private ScheduledFuture<?> taskFuture;
    private final TaskScheduler taskScheduler;

    public YourEventScanTask(TaskScheduler taskScheduler) {
        this.taskScheduler = taskScheduler;
    }

    @PostConstruct
    public void registerTask() {
        taskFuture = taskScheduler.scheduleAtFixedRate(this::scanNewRecords, Duration.ofSeconds(1));
    }

    private void scanNewRecords() {
        // 你的扫描数据库逻辑
    }

    @PreDestroy
    public void cancelTask() {
        if (taskFuture != null && !taskFuture.isCancelled()) {
            taskFuture.cancel(true);
        }
    }
}

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