Spring Boot 3.2与Java 21下并行任务阻塞问题求助

1. Spring上下文初始化死锁 #

Spring Boot 3.2 调整了Bean初始化的线程模型与时机，若DataLoader是Spring管理的Bean，且主线程在future.get()处阻塞等待并行任务完成时，MongoRepository或其依赖的MongoTemplate尚未完成初始化，会导致所有并行任务阻塞等待依赖就绪，主线程又无法继续推进上下文初始化，形成死锁。

处理方案：

• 显式声明依赖关系：给DataLoader添加@DependsOn注解，指定依赖的MongoRepository Bean，确保依赖先完成初始化。
• 延后数据加载时机：将并行加载逻辑移到Spring上下文完全初始化后执行，比如实现ApplicationRunner接口，在run方法中触发加载：

  @Component
  public class DataLoaderRunner implements ApplicationRunner {
      private final List<DataLoader> dataLoaders;
  
      public DataLoaderRunner(List<DataLoader> dataLoaders) {
          this.dataLoaders = dataLoaders;
      }
  
      @Override
      public void run(ApplicationArguments args) throws Exception {
          ExecutorService executorService = Executors.newFixedThreadPool(Math.min(dataLoaders.size(), 10));
          List<Future<?>> futures = new ArrayList<>();
          for (DataLoader dataLoader : dataLoaders) {
              futures.add(executorService.submit(dataLoader::load));
          }
          try {
              for (Future<?> future : futures) {
                  future.get(5, TimeUnit.MINUTES);
              }
          } catch (InterruptedException | ExecutionException | TimeoutException e) {
              throw new RuntimeException("Can not initialize", e);
          } finally {
              executorService.shutdown();
          }
      }
  }
  

2. MongoDB驱动与Java 21线程兼容性问题 #

Spring Boot 3.2 默认适配的MongoDB驱动（4.10+）在Java 21环境下，可能因线程模型适配问题导致阻塞，比如驱动内部线程池与自定义线程池竞争连接资源，或虚拟线程特性引发的异常。

处理方案：

• 显式配置MongoDB连接池：在application.yml中指定连接池大小，避免连接耗尽：

  spring:
    data:
      mongodb:
        connection-pool:
          max-size: 20
          min-size: 5
  

• 禁用虚拟线程测试：添加启动参数-Dspring.threads.virtual.enabled=false，切换回平台线程验证是否恢复正常。

3. 自定义线程池资源过载 #

若dataLoaders.size()过大，newFixedThreadPool(dataLoaders.size())会创建过多线程，每个线程都等待MongoDB连接，导致连接池耗尽，所有任务陷入阻塞；或load()方法未捕获异常导致线程静默挂起。

处理方案：

• 限制线程池大小：将线程池大小设为固定值（如Math.min(dataLoaders.size(), 10)），避免创建过多线程。
• 增强load()方法的异常处理与日志：在load()内部添加try-catch块，打印关键节点日志（开始加载、查询MongoDB、完成加载），定位阻塞点：

  public void load() {
      try {
          log.info("Start loading data for collection: {}", getCollectionName());
          // 分批次查询逻辑
          log.info("Finish loading data for collection: {}", getCollectionName());
      } catch (Exception e) {
          log.error("Failed to load data for collection: {}", getCollectionName(), e);
          throw e;
      }
  }
  

4. Java 21并发API行为变化 #

Java 21对ExecutorService和Future的中断、超时处理逻辑做了微调，可能导致旧代码在新环境下出现无限阻塞。

处理方案：

• 给future.get()添加超时时间：快速定位卡住的任务，便于排查：

  future.get(5, TimeUnit.MINUTES);
  

• 改用Spring的ThreadPoolTaskExecutor：利用Spring封装的线程池管理机制，避免原生API的兼容性问题。

内容的提问来源于stack exchange，提问作者Александр Родин