ThreadPoolExecutor嵌套任务引发线程池阻塞问题求助

线程确实处于阻塞（死锁）状态 #

从线程栈信息可以看到，线程卡在CompletableFuture.get()方法上，处于WAITING状态，这是典型的线程池死锁场景：所有工作线程被占用，且都在等待其他需要该线程池执行的任务完成，形成循环等待闭环。

死锁原因拆解 #

你的代码逻辑结合线程池特性，触发了死锁：

• 线程池核心线程数设为10，外层test()方法提交了10个任务，刚好占满所有核心线程。
• 每个外层任务内部创建100个内层任务提交到同一线程池，随后调用inner.invokeAll()——也就是通过CompletableFuture.get()阻塞等待内层任务完成。
• 此时线程池的10个工作线程全被外层任务占用，每个线程都在等待内层任务执行，但内层任务没有空闲线程可运行，形成“外层线程等内层任务，内层任务等空闲线程”的死锁。

为什么单一InvokeCollection或ForkJoinPool能正常运行 #

单一InvokeCollection的情况 #

所有任务扁平化提交到同一个集合，没有任务会在执行过程中阻塞等待其他任务，线程池线程可以依次处理任务，不会出现循环等待。

ForkJoinPool的情况 #

ForkJoinPool核心特性是工作窃取（Work Stealing）：当线程等待自身提交的子任务时，会主动去其他线程的任务队列偷取未执行任务来执行，而非空等。这种机制避免了线程被阻塞浪费，自然不会出现ThreadPoolExecutor式的死锁。

解决方案 #

1. 扁平化任务结构：避免在提交给线程池的任务内部，等待同一线程池执行的子任务。将所有任务直接提交到外层集合统一等待：

   @GetMapping("test")
   public void test(){
       System.out.println("request=======================");
       AsyncInvoker.InvokeCollection allTasks = asyncInvoker.newCollection();
       for (int i = 0; i < 10; i++) {
           for (int j = 0; j < 100; j++) {
               allTasks.add(()->{
                   try {
                       Thread.sleep(100);
                       System.out.println("===");
                   }catch (Exception e) {
                       e.printStackTrace();
                   }
               });
           }
       }
       allTasks.invokeAll();
   }
   

2. 改用支持工作窃取的线程池：若必须保留嵌套任务结构，直接使用ForkJoinPool作为执行器，其工作窃取机制可避免此类死锁。
3. 异步回调替代阻塞等待：任务内部不要用get()阻塞，改用CompletableFuture的thenRun、thenAccept等异步回调方法，让流程异步化，避免占用线程池线程。

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