java中可通过重写threadpoolexecutor的beforeexecute和afterexecute实现轻量级监控：前者记录开始时间、注入mdc、设置线程名；后者统计耗时、捕获异常、清理资源，开销低且覆盖所有执行路径。
Java中可以通过继承 ThreadPoolExecutor 并重写 beforeExecute 和 afterExecute 方法，实现对线程池任务执行生命周期的监控，这是轻量级、无侵入的“切面式”监控方案。
为什么用 beforeExecute/afterExecute 做监控切面
这两个钩子方法在任务实际执行前后被调用（由工作线程触发），天然具备上下文信息：Thread、Runnable（或 Future）、异常等。相比 AOP 代理 Runnable 或拦截 submit，它不依赖反射、不修改任务对象、不增加额外对象分配，开销极低，且能精准覆盖所有执行路径（包括 execute() 和 submit()）。
重写 beforeExecute：记录任务开始时间与上下文
在任务真正运行前捕获快照，常用于统计排队时长、绑定 MDC、标记线程身份等：
- 把当前时间戳存入
ThreadLocal<long></long>，供后续afterExecute计算耗时 - 将任务的业务标识（如 traceId、method name）注入 SLF4J 的
MDC，保障日志可追溯 - 记录线程名称变化（例如设置为
"biz-pool-task-" + taskId），便于线程堆栈分析 - 注意：不要在此处做耗时操作（如远程调用、DB 写入），否则会阻塞工作线程
重写 afterExecute：统计耗时、捕获异常、清理资源
该方法在任务执行完成（无论正常结束还是抛异常）后调用，是监控闭环的关键点：
- 从
ThreadLocal取出开始时间，结合当前时间计算执行耗时，上报到指标系统（如 Micrometer 的 Timer） - 检查
Throwable t参数：若非 null，说明任务执行中抛出了未捕获异常，可记录错误率、告警或采样堆栈 - 清空
MDC防止脏数据泄漏到下一个任务；清除ThreadLocal中的时间戳，避免内存泄漏 - 对
FutureTask类型的任务，可通过((FutureTask) r).get()获取返回值（慎用，可能阻塞）
完整示例：带监控指标的自定义线程池
以下是一个精简可用的实现片段（基于 Micrometer）：
public class MonitoredThreadPoolExecutor extends ThreadPoolExecutor {
private final Timer taskTimer;
private final Counter errorCounter;
private final ThreadLocal<long> startTime = ThreadLocal.withInitial(System::nanoTime);
<pre class="brush:java;toolbar:false;">public MonitoredThreadPoolExecutor(
int corePoolSize, int maxPoolSize, long keepAliveTime, TimeUnit unit,
BlockingQueue<Runnable> workQueue, MeterRegistry registry) {
super(corePoolSize, maxPoolSize, keepAliveTime, unit, workQueue);
this.taskTimer = Timer.builder("threadpool.task.duration")
.tag("pool", "biz")
.register(registry);
this.errorCounter = Counter.builder("threadpool.task.error")
.tag("pool", "biz")
.register(registry);
}
@Override
protected void beforeExecute(Thread t, Runnable r) {
super.beforeExecute(t, r);
startTime.set(System.nanoTime());
if (r instanceof RunnableTask) {
MDC.put("taskId", ((RunnableTask) r).getId());
}
}
@Override
protected void afterExecute(Runnable r, Throwable t) {
super.afterExecute(r, t);
long elapsed = System.nanoTime() - startTime.get();
startTime.remove();
MDC.clear();
taskTimer.record(elapsed, TimeUnit.NANOSECONDS);
if (t != null) {
errorCounter.increment();
log.warn("Task failed with exception", t);
}
}
}
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
