4. 多线程与自定义线程池：配置@EnableAsync与ThreadPoolTaskScheduler，解决任务互相阻塞的问题

在默认情况下，Spring Boot 的 @Scheduled 注解使用一个单线程的 TaskScheduler 来执行所有定时任务。这意味着，如果第一个任务执行时间过长，后续任务将被迫排队等待，形成严重的任务互相阻塞（Blocking）现象。本章将深入剖析这一问题的根源，并演示如何通过 @EnableAsync 与自定义 ThreadPoolTaskScheduler 来构建多线程调度环境，彻底解决任务阻塞。

4.1 单线程调度器的阻塞陷阱

Spring 默认的 TaskScheduler 实现是 ConcurrentTaskScheduler，它内部包装了一个单线程的 ScheduledExecutorService（大小为 1）。当多个 @Scheduled 方法被触发时，它们会被提交到同一个线程中顺序执行。

下表总结了单线程与多线程调度器的核心差异：

4.2 核心解决方案：@EnableAsync + ThreadPoolTaskScheduler

Spring 提供了 @EnableAsync 注解来开启异步执行支持，结合自定义的 ThreadPoolTaskScheduler，可以轻松实现定时任务的并发调度。其核心思路是：将定时任务的触发与执行分离，触发由调度线程池负责，执行则交由异步线程池处理。

以下是一个完整的配置示例：

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

import java.util.concurrent.Executor;

@Configuration
@EnableAsync
public class SchedulerConfig implements AsyncConfigurer {

    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.setPoolSize(10);               // 核心线程数
        scheduler.setThreadNamePrefix("async-task-"); // 线程名前缀
        scheduler.setWaitForTasksToCompleteOnShutdown(true); // 优雅关闭
        scheduler.setAwaitTerminationSeconds(30); // 等待任务完成的最大秒数
        scheduler.setRejectedExecutionHandler(new java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy()); // 拒绝策略
        scheduler.initialize();
        return scheduler;
    }
}

在定时任务类中使用 @Async：

import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@Component
public class AsyncScheduledTasks {

    @Async
    @Scheduled(fixedDelay = 5000)
    public void taskA() throws InterruptedException {
        System.out.println(Thread.currentThread().getName() + " - 任务A开始");
        Thread.sleep(10000); // 模拟耗时操作
        System.out.println(Thread.currentThread().getName() + " - 任务A结束");
    }

    @Async
    @Scheduled(fixedRate = 2000)
    public void taskB() {
        System.out.println(Thread.currentThread().getName() + " - 任务B执行");
    }
}

4.3 线程池参数调优与拒绝策略

自定义线程池的参数需要根据业务场景进行调优。下表列出了 ThreadPoolTaskScheduler 的核心参数及其推荐值：

4.4 架构流程：从单线程阻塞到多线程并发

下面的 SVG 图展示了从默认单线程调度到自定义多线程调度的架构演变，清晰对比了任务执行路径的差异。

4.5 故障排查清单：阻塞问题定位

当怀疑定时任务存在阻塞问题时，可以按照以下清单进行排查：

• 检查线程转储（Thread Dump）：使用 jstack 或 VisualVM 查看 scheduling-1 线程是否长时间处于 RUNNABLE 或 BLOCKED 状态。
• 启用调度日志：在 application.yml 中设置 logging.level.org.springframework.scheduling=DEBUG，观察任务提交与执行的时间戳。
• 验证线程池配置：通过 actuator/beans 端点确认 taskScheduler 的 poolSize 是否为 1。
• 模拟长任务：在测试环境注入 Thread.sleep() 模拟耗时操作，观察其他任务是否被延迟。
• 监控任务执行时间：使用 @Timed 或自定义 AOP 记录每个 @Scheduled 方法的实际执行耗时。

# 查看 Java 进程 ID
jps -l

# 导出线程转储
jstack <PID> > threaddump.txt

# 在转储文件中搜索调度线程
grep "scheduling-1" threaddump.txt

4.6 最佳实践与避坑指南

在配置多线程调度时，需要注意以下常见陷阱：