如何查看Spring Boot 3中@Async任务的线程队列等待情况？

一、查看队列中等待执行的任务 #

Spring Boot默认使用ThreadPoolTaskExecutor作为异步任务执行器，要获取队列等待任务状态，直接注入该Bean并调用队列相关方法即可：

• 注入执行器实例：

  @Autowired
  private ThreadPoolTaskExecutor taskExecutor;
  

• 获取队列状态相关数据：

  // 获取队列中等待执行的任务数量
  int waitingTaskCount = taskExecutor.getThreadPoolExecutor().getQueue().size();
  // 获取队列剩余可容纳任务数
  int remainingQueueCapacity = taskExecutor.getThreadPoolExecutor().getQueue().remainingCapacity();
  // 获取已提交但未完成的任务总数（含队列等待+正在执行的任务）
  long totalPendingTasks = taskExecutor.getThreadPoolExecutor().getTaskCount() - taskExecutor.getThreadPoolExecutor().getCompletedTaskCount();
  

如果是自定义Bean方式配置的执行器，只要基于ThreadPoolExecutor实现，都可以用上述方法获取队列状态。

二、监控异步任务配置与动态调整 #

1. 实时查看当前运行参数 #

通过执行器对象直接获取线程池当前配置及运行状态：

// 获取当前核心线程数
int currentCoreSize = taskExecutor.getCorePoolSize();
// 获取当前最大线程数
int currentMaxSize = taskExecutor.getMaxPoolSize();
// 获取队列总容量
int totalQueueCapacity = taskExecutor.getThreadPoolExecutor().getQueue().size() + taskExecutor.getThreadPoolExecutor().getQueue().remainingCapacity();
// 获取线程存活时间（单位：秒）
long keepAliveSeconds = taskExecutor.getKeepAliveSeconds();

2. 动态调整线程池参数 #

ThreadPoolTaskExecutor支持运行时动态调整核心线程数、最大线程数及线程存活时间：

// 动态修改核心线程数
taskExecutor.setCorePoolSize(40);
// 动态修改最大线程数
taskExecutor.setMaxPoolSize(70);
// 动态修改线程存活时间（单位：秒）
taskExecutor.setKeepAliveSeconds(15);

注意：队列容量无法动态调整，因为队列初始化后大小固定。如果需要可变容量的队列，可在自定义执行器时选用LinkedBlockingDeque等无界队列，但要警惕内存溢出风险。

3. 集成Spring Boot Actuator系统化监控 #

通过Spring Boot Actuator可以更便捷地监控线程池状态：

• 引入Actuator依赖：

  <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-actuator</artifactId>
  </dependency>
  

• 在application.properties中开启线程池监控端点：

  management.endpoints.web.exposure.include=threadpool
  management.endpoint.threadpool.enabled=true
  

启动应用后访问/actuator/threadpool，即可查看所有线程池的详细监控数据，包括队列等待任务数、活跃线程数、已完成任务数等。

三、注意事项 #

• 若存在多个自定义异步执行器，注入时需用@Qualifier指定对应Bean名称。
• 核心线程数调整会立即生效，最大线程数调整仅对新创建的线程生效。
• 使用无界队列时，需结合业务流量预估设置合理的线程数上限，避免内存溢出。

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