SafeExecutor 是对任务执行入口的增强封装，通过统一包装 Runnable/Callable 实现异常转交而非吞掉，利用代理提交、钩子或 ThreadFactory 联动 UncaughtExceptionHandler，确保异常可审计、上下文可追溯、可观测性闭环。
直接在任务提交层做统一包装，比每个任务自己 try-catch 更轻量、更可控。关键不是“捕获后吞掉”，而是“捕获后转交”，让异常浮出水面并可被统一审计。
SafeExecutor 的核心设计原则
它不是替代线程池，而是对 任务执行入口 的增强封装。目标有三个：
- 所有 Runnable/Callable 提交前自动包裹，不侵入业务逻辑
- 未处理异常不静默丢失，统一转为可感知的回调或日志事件
- 保留原始堆栈、任务标识（如 traceId、taskName）、执行上下文
基于 ThreadPoolExecutor 的 SafeExecutor 实现
利用 ThreadPoolExecutor 的 beforeExecute 和 afterExecute 钩子，或更推荐的方式：在 execute()/submit() 调用前做代理包装。
推荐做法是封装一个 SafeExecutorService，内部持有真实线程池，并重写提交方法：
-
execute(Runnable r)→ 包装为SafeRunnable(r) -
submit(Callable<T> task)→ 包装为SafeCallable(task) -
submit(Runnable task, T result)→ 同样包装为SafeRunnable并携带 result
SafeRunnable 示例：
class SafeRunnable implements Runnable {
private final Runnable delegate;
private final String taskName;
private final Supplier<String> traceIdSupplier;
SafeRunnable(Runnable delegate, String taskName, Supplier<String> traceIdSupplier) {
this.delegate = delegate;
this.taskName = taskName;
this.traceIdSupplier = traceIdSupplier;
}
@Override
public void run() {
try {
delegate.run();
} catch (Throwable t) {
// 1. 记录结构化日志（含 traceId、taskName、t）
auditLogger.error("Async task failed", Map.of(
"task", taskName,
"traceId", traceIdSupplier.get(),
"exception", t.toString()
), t);
// 2. 可选：触发告警、补偿队列、Metrics 计数
exceptionCounter.increment();
// 3. 不吞异常 —— 若需外抛，可抛给线程默认异常处理器（见下条）
Thread.currentThread().getUncaughtExceptionHandler()
.uncaughtException(Thread.currentThread(), t);
}
}
}
与线程默认异常处理器联动
确保线程池创建时设置了自定义的 ThreadFactory，让每个工作线程都绑定统一的 UncaughtExceptionHandler：
- 该处理器可将异常转发至审计中心（如 Kafka Topic、ELK、Sentry）
- 避免依赖
Future.get()主动拉取，解决 submit + 忘记 get 的漏报问题 - 对 execute 提交的任务天然生效，无需改造调用方
审计能力扩展建议
SafeExecutor 不止于“记录”，还可支撑可观测性闭环：
- 为每个任务生成唯一
taskId，贯穿日志、指标、链路追踪 - 异常类型分类统计（NPE / Timeout / DBException），驱动根因分析
- 支持动态开关：灰度开启全量异常采样，或仅记录 ERROR 级别
- 与 Spring AOP 或 Agent 结合，自动注入 traceId 和业务标签
不复杂但容易忽略：真正落地时，重点不在包装器本身，而在于审计出口是否可靠、是否与现有监控体系打通。
