Spring ThreadPoolTaskExecutor线程数超出核心池与最大池限制问题排查

可能的原因 #

1. 核心线程因超时被销毁，新请求重复创建线程 #

你设置了allowCoreThreadTimeOut(true)和keepAliveSeconds(30)，这会让核心线程在空闲30秒后被销毁。如果请求是间隔性到来（间隔超过30秒），每次新请求进来时没有可用的核心线程，就会创建新的核心线程，导致线程名持续递增（比如My Thread-1到My Thread-300）。但同时运行的线程数不会超过corePoolSize=2，你看到的只是累计创建的线程数，而非并发线程数。

2. 自定义线程池未被Spring正确加载 #

如果定义@Bean的方法所在类没有添加@Configuration注解，Spring不会将这个线程池注册为Bean。此时@Async("My Thread Pool")找不到指定线程池，会使用默认的SimpleAsyncTaskExecutor——这个执行器每次处理任务都会创建新线程，直接导致线程数无限制增长。不过从你给出的线程名前缀来看，这种可能性较低，但仍需验证。

修复方案 #

方案1：保留核心线程，避免重复创建 #

如果希望核心线程一直存活，去掉allowCoreThreadTimeOut(true)的配置：

@Bean(name = "My Thread Pool")
public Executor myTaskExecutor() {
  ThreadPoolTaskExecutor pool = new ThreadPoolTaskExecutor();
  pool.setCorePoolSize(2);
  pool.setMaxPoolSize(3);
  pool.setKeepAliveSeconds(30);
  // 移除allowCoreThreadTimeOut(true)
  pool.setWaitForTasksToCompleteOnShutdown(true);
  pool.setThreadNamePrefix("My Thread-");
  return pool;
}

这样核心线程不会因空闲超时被销毁，线程数会稳定在corePoolSize=2，线程名也不会持续递增。

方案2：确认线程池Bean被正确加载 #

确保定义myTaskExecutor()方法的类添加了@Configuration注解，让Spring能够扫描并注册这个线程池Bean：

@Configuration
public class ThreadPoolConfig {
  @Bean(name = "My Thread Pool")
  public Executor myTaskExecutor() {
    // 线程池配置代码
  }
}

方案3：验证实际线程数 #

在sayHello()方法中添加线程池状态打印，确认并发线程数是否真的超过限制（推荐通过依赖注入获取线程池Bean，更符合Spring规范）：

@Service
class Welcome {
    private final ThreadPoolTaskExecutor myTaskExecutor;

    // 构造注入线程池Bean
    public Welcome(@Qualifier("My Thread Pool") ThreadPoolTaskExecutor myTaskExecutor) {
        this.myTaskExecutor = myTaskExecutor;
    }

    @Async("My Thread Pool")
    public void sayHello() {
        System.out.println("当前活跃线程数: " + myTaskExecutor.getActiveCount());
        System.out.println("当前线程池总大小: " + myTaskExecutor.getPoolSize());
        System.out.println("线程名称: " + Thread.currentThread().getName());
    }
}

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