beforeExecute 是 ThreadPoolExecutor 的受保护钩子，在任务执行前由工作线程同步调用，适用于记录上下文、快照 ThreadLocal、埋点监控等；需继承并重写，注意异常处理与性能影响。
ThreadPoolExecutor 的 beforeExecute 方法是一个受保护的钩子（hook），在每个任务被线程实际执行前由工作线程调用。它不参与任务调度逻辑，但非常适合用于**记录上下文、快照线程局部变量、埋点监控、权限校验或资源预检查**等场景。实战中，它最常被用来记录任务执行前的关键状态——比如当前线程绑定的用户身份、请求 ID、事务上下文、日志 MDC 信息等。
继承 ThreadPoolExecutor 并重写 beforeExecute
要使用该钩子，需继承 ThreadPoolExecutor 并覆写 beforeExecute(Thread t, Runnable r) 方法：
- 参数
t是即将执行任务的工作线程（可用于识别线程名、获取 ThreadLocal） - 参数
r是待执行的Runnable（注意：若使用submit(Callable)，实际传入的是内部包装的FutureTask，不是原始 Callable） - 该方法在任务 run() 调用前同步执行，且与任务同线程（即在工作线程上下文中运行）
记录 ThreadLocal 变量状态（如 MDC、用户上下文）
很多 Web 框架（如 Spring MVC）会在请求入口将 traceId、userId 等存入 MDC 或自定义 ThreadLocal。但线程池复用线程后，这些上下文可能残留或丢失。利用 beforeExecute 可安全“快照”并记录关键字段：
- 读取
MDC.get("traceId")、SecurityContextHolder.getContext().getAuthentication()等 - 将值写入日志（建议打 INFO 或 DEBUG 级别，避免高频刷盘）
- 也可将快照保存到任务对象中（需确保
r是你可控的自定义 Runnable 类型）
protected void beforeExecute(Thread t, Runnable r) {
super.beforeExecute(t, r);
String traceId = MDC.get("traceId");
log.debug("[{}] task entering pool: {}, traceId={}", t.getName(), r.getClass().getSimpleName(), traceId);
}
结合自定义 Runnable 做更精准的状态捕获
单纯依赖 beforeExecute 无法直接访问业务参数。若需记录具体任务入参（如订单 ID、用户操作类型），推荐组合方案：
- 定义自己的
TracedRunnable，构造时捕获当前上下文（如new TracedRunnable(runnable, MDC.getCopyOfContextMap())） - 在
beforeExecute中判断r instanceof TracedRunnable，然后提取并记录其携带的上下文 - 这样既保证了上下文被捕获在提交时刻（非执行时刻），又避免了线程间污染
注意事项与避坑点
-
beforeExecute抛出异常会导致该任务被跳过（不会进入afterExecute），且线程可能终止 —— 所以务必用 try-catch 包裹日志/快照逻辑 - 不要在其中做耗时操作（如远程调用、DB 查询），否则会阻塞工作线程，拖慢整个线程池吞吐
- 不能修改任务行为（如替换
r），因为此时已无法影响调度器；如需拦截/改写，应使用RejectedExecutionHandler或装饰 ExecutorService - 若使用
ForkJoinPool或第三方线程池（如 Netty EventLoop），该钩子不生效
