Java中如何非JFR方式检测Lmax Disruptor消费线程工作状态？

针对你遇到的WorkerPool仅单个线程处理所有事件的问题，以下是无需依赖JFR、可提前检测的指标，分为线程池原生指标、Disruptor专属指标和JVM线程指标三类：

一、线程池原生统计指标 #

如果你的ConsumerPool是基于ThreadPoolExecutor实现的，可直接通过以下API获取状态：

• 活跃线程数：调用getActiveCount()，若返回值始终为1（远小于配置的POOL_SIZE），说明只有单个线程在处理任务。
• 线程任务完成数：自定义线程池时，给每个线程绑定任务计数器（比如通过ThreadLocal<AtomicLong>），或扩展线程池实现单个线程的完成任务数统计。若仅单个线程的完成数持续增长，其他线程数值几乎不变，即可判定负载集中。
• 线程状态分布：调用getThreads()获取所有线程实例，通过getState()查看状态。若大部分线程处于WAITING/TIMED_WAITING状态，仅一个线程为RUNNABLE，说明其余线程未被分配任务。

二、Disruptor专属指标 #

利用Disruptor自身的序列（Sequence）机制，直接监控消费者的工作状态：

• 消费者序列进度：通过disruptor.getConsumerRepository().getWorkerPoolSequences()获取WorkerPool中所有消费者的Sequence实例。定期对比各序列的get()返回值，若仅最后一个序列的数值持续快速增长，其他序列几乎无变化，说明该消费者承担了全部事件处理工作。
• 事件处理线程计数：在你的GenericEvent处理器的onEvent方法中，添加线程本地计数器：

  private static final ThreadLocal<AtomicLong> EVENT_COUNT = ThreadLocal.withInitial(AtomicLong::new);
  
  @Override
  public void onEvent(GenericEvent event, long sequence, boolean endOfBatch) throws Exception {
      // 业务逻辑处理
      EVENT_COUNT.get().incrementAndGet();
  }
  

  定期收集所有线程的计数并对比，若仅单个线程的计数持续上升，即可提前发现负载不均问题。

三、JVM线程维度指标 #

通过JVM自带工具或JMX API获取线程运行数据，无需等待应用变慢：

• 线程CPU时间占比：使用ThreadMXBean的getThreadCpuTime()方法，定期采样所有消费线程的CPU耗时。若仅单个线程的CPU时间持续走高，其他线程耗时几乎为0，说明该线程在处理所有任务。
• 线程阻塞/等待次数：通过ThreadMXBean.getThreadInfo(long[] ids, int maxDepth)获取线程的阻塞、等待次数统计。若仅单个线程的阻塞/等待次数持续变化，其他线程无数据更新，即可判定负载集中。

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