自定义ThreadPoolTaskExecutor提交多线程后停止工作的问题咨询

1. 自定义线程池Bean未正确返回实例
   你的executor()方法没有返回创建的ThreadPoolTaskExecutor实例，导致Spring无法注入有效线程池，此时CompletableFuture.supplyAsync会 fallback 到JDK默认的ForkJoinPool.commonPool()。而ForkJoinPool默认线程数为CPU核心数-1（例如8核CPU仅7个工作线程），200并发请求涌入时线程池瞬间被占满，任务大量堆积阻塞，最终程序停止响应。

2. @Async与CompletableFuture的双重异步叠加
   方法同时标注@Async且内部使用CompletableFuture.supplyAsync，导致双层异步执行：

   • Spring的@Async将整个方法提交到默认异步线程池；
   • 方法内部又将数据库查询任务提交到自定义线程池。
     200并发请求会同时占用两层线程池资源，若默认线程池无界创建线程，会导致系统线程资源耗尽，引发任务阻塞。

3. 线程池拒绝策略未适配场景
   即使自定义线程池正确初始化，默认的AbortPolicy拒绝策略会在队列满且线程数达上限时抛出RejectedExecutionException，但该异常会被CompletableFuture静默捕获，无法被感知，后续任务持续堆积最终导致系统无响应。

1. 修复自定义线程池Bean的定义
   确保方法返回线程池实例，并添加必要配置：

   @Bean
   Executor customAsyncExecutor() {
       ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
       executor.setCorePoolSize(48);
       executor.setMaxPoolSize(48);
       executor.setQueueCapacity(10000);
       executor.setThreadNamePrefix("CustomAsync-");
       // 配置CallerRunsPolicy，让调用线程执行任务避免直接丢弃
       executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
       executor.initialize(); // Spring管理时可省略，手动创建需调用
       return executor;
   }
   

2. 移除不必要的双重异步
   选择一种异步方式即可：

   • 方式一：用@Async指定自定义线程池

     @Override
     @Async("customAsyncExecutor")
     public CompletableFuture<List<Activity>> findAllAndMakeAFuture() {
         log.info("Current thread: {}", Thread.currentThread());
         return CompletableFuture.completedFuture(activityRepository.findsAll());
     }
     

   • 方式二：仅使用内部CompletableFuture

     @Override
     public CompletableFuture<List<Activity>> findAllAndMakeAFutureWithDedicatedExecutor(@Qualifier("customAsyncExecutor") Executor executor) {
         return CompletableFuture.supplyAsync(() -> {
             log.info("Current thread: {}", Thread.currentThread());
             return activityRepository.findsAll();
         }, executor);
     }
     

3. 调整线程池参数适配压测场景

   • 若数据库查询是IO密集型操作，可适当增大核心线程数（如CPU核心数*2）；
   • 队列容量不宜过大，避免任务堆积导致内存占用过高；
   • 根据业务场景选择合适的拒绝策略，避免请求丢失或系统崩溃。

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