可通过继承ThreadPoolExecutor并重写beforeExecute、afterExecute、terminated钩子方法嵌入监控逻辑，配合日志框架记录任务执行细节、运行指标及上下文信息，并通过采样、分级日志和指标上报实现高效可观测性。
在 Java 中，可以通过继承 ThreadPoolExecutor 并重写其关键生命周期方法（如 beforeExecute、afterExecute、terminated）来嵌入监控逻辑，再配合日志框架（如 SLF4J + Logback）输出线程池运行时指标和任务行为。
重写钩子方法记录任务执行细节
核心是利用 ThreadPoolExecutor 提供的三个受保护的钩子方法，在任务执行前后注入日志。这些方法在线程池内部被安全调用，无需额外同步：
-
beforeExecute(Thread t, Runnable r)：任务开始前记录线程名、任务标识（如r.getClass().getSimpleName()或自定义toString()）、提交时间戳； -
afterExecute(Runnable r, Throwable t)：任务结束后记录耗时（可基于System.nanoTime()差值）、是否异常（t != null）、线程池当前活跃线程数（getActiveCount()）、队列剩余任务数（getQueue().size()）； -
terminated()：在线程池彻底关闭后记录最终统计，比如总完成任务数（getCompletedTaskCount()）、最大并发数等。
为任务添加可识别的上下文信息
单纯打印 Runnable 类名往往不够，建议让业务任务实现统一接口或包装为带 ID/标签的封装类：
- 定义
TracedTask接口，含getTaskId()和getTag()方法； - 在
beforeExecute中尝试强转：if (r instanceof TracedTask) { log.info("Start task: {}, tag: {}", ((TracedTask) r).getTaskId(), ((TracedTask) r).getTag()); }； - 对非侵入式场景，可用
ThreadLocal在提交任务时预设追踪 ID，并在钩子中读取（需注意清理，避免内存泄漏）。
定期采集并上报线程池运行指标
除单次任务日志外，还可启动一个守护线程，周期性（如每 10 秒）打印关键指标，辅助发现长周期问题：
立即学习“Java免费学习笔记（深入）”；
- 使用
ScheduledExecutorService调用log.info("Pool[{}]: active={}, queue={}, completed={}, largest={}", poolName, getActiveCount(), getQueue().size(), getCompletedTaskCount(), getLargestPoolSize())； - 重点关注
getQueue().size()持续增长、getActiveCount() == getPoolSize()长期满载、getLargestPoolSize()频繁扩容等信号； - 可将指标导出为 Micrometer 的
Gauge或 Prometheus 格式，接入监控系统。
避免日志干扰与性能损耗
高频日志可能拖慢线程池，需合理控制粒度和级别：
- 将详细执行日志设为
DEBUG级，生产环境默认关闭；关键异常和超时任务用WARN或ERROR； - 避免在
afterExecute中做耗时操作（如 IO、远程调用），只记录必要字段； - 对高吞吐场景，可采样日志（如每 100 个任务记录 1 条），或仅对执行时间 > 阈值（如 5s）的任务打标记录。
不复杂但容易忽略的是：务必在自定义子类中调用父类构造器，并确保所有创建方式（如通过 Executors 工具类）都替换为你自己的实现类——否则钩子不会生效。
