最直接有效的方式是继承ThreadPoolExecutor并重写beforeExecute、afterExecute和rejectedExecution等钩子方法，在任务提交、执行、完成、拒绝环节埋点采集指标，同时用AtomicLong维护线程安全的统计变量并提供指标读取接口。
要给Java线程池加监控，最直接有效的方式是继承 ThreadPoolExecutor，重写关键回调方法，在任务提交、执行、完成、拒绝等环节埋点采集指标。
重写核心回调方法，捕获全生命周期事件
ThreadPoolExecutor 提供了多个可重写的钩子方法，不需要修改原有逻辑就能插入监控逻辑：
-
beforeExecute(Thread t, Runnable r)：任务真正开始执行前调用，适合记录开始时间、线程ID、当前活跃线程数 -
afterExecute(Runnable r, Throwable t)：任务执行结束后调用（无论成功或异常），适合统计耗时、异常类型、完成状态 -
rejectedExecution(Runnable r, ThreadPoolExecutor executor)：任务被拒绝时触发，可用于告警、降级或记录拒绝原因（如队列满、线程数已达上限）
暴露可观察指标，对接常用监控体系
在自定义线程池中维护原子计数器和统计变量，提供安全读取接口：
- 用
AtomicLong记录总提交数、总完成数、总拒绝数 - 用
AtomicLong统计累计执行时间，配合System.nanoTime()精确计算单任务耗时 - 提供
getActiveCount()、getQueueSize()、getLargestPoolSize()等标准方法的增强版，返回带时间戳或标签的指标快照 - 支持通过 JMX 注册 MBean，或实现 Micrometer 的
MeterRegistry接口，无缝接入 Prometheus/Grafana
避免常见陷阱：线程安全与性能影响
监控逻辑必须轻量且线程安全，否则反而拖慢线程池：
立即学习“Java免费学习笔记（深入）”；
- 不要在
beforeExecute或afterExecute中做 I/O、远程调用或锁竞争操作，只做内存计数和时间采样 - 统计耗时建议用
System.nanoTime()而非System.currentTimeMillis()，避免时钟回拨干扰 - 若需聚合高频率指标（如每秒任务数），可用环形缓冲区或滑动窗口结构，避免频繁对象创建
- 拒绝策略监控应区分类型（
AbortPolicy、CallerRunsPolicy等），不同策略代表不同系统瓶颈信号
实战示例：一个可落地的监控线程池骨架
以下是一个精简但完整的扩展类结构：
public class MonitoredThreadPoolExecutor extends ThreadPoolExecutor {
private final AtomicLong submittedCount = new AtomicLong();
private final AtomicLong completedCount = new AtomicLong();
private final AtomicLong rejectedCount = new AtomicLong();
private final AtomicLong totalNanos = new AtomicLong();
public MonitoredThreadPoolExecutor(int corePoolSize, int maxPoolSize,
long keepAliveTime, TimeUnit unit,
BlockingQueue<Runnable> workQueue) {
super(corePoolSize, maxPoolSize, keepAliveTime, unit, workQueue);
}
@Override
protected void beforeExecute(Thread t, Runnable r) {
super.beforeExecute(t, r);
submittedCount.incrementAndGet();
}
@Override
protected void afterExecute(Runnable r, Throwable t) {
super.afterExecute(r, t);
completedCount.incrementAndGet();
// 实际使用中可在此处结合 ThreadLocal 存储开始时间
}
@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
rejectedCount.incrementAndGet();
super.rejectedExecution(r, executor);
}
// 提供指标获取方法，供 Prometheus Collector 或健康检查调用
public long getSubmittedCount() { return submittedCount.get(); }
public long getCompletedCount() { return completedCount.get(); }
public long getRejectedCount() { return rejectedCount.get(); }
} 
