Java线程池不自动记录submit任务的异常，需通过自定义ThreadFactory命名线程+包装Runnable/Callable捕获异常实现详细日志（含线程名、任务名、时间、堆栈等），并可扩展ThreadPoolExecutor自动包装任务。
Java 线程池本身不自动记录任务执行异常，尤其是被 submit() 提交的 Runnable 或 Callable 中抛出的未捕获异常——它们会被吞掉，仅通过 Thread.UncaughtExceptionHandler（默认只打印堆栈到 stderr）简单处理。要实现**详细错误日志记录**（如线程名、任务类、触发时间、完整堆栈、甚至任务参数），关键不是靠“线程池工厂”本身，而是结合自定义 ThreadFactory 与**任务包装 + 异常拦截机制**。
1. 自定义 ThreadFactory：为线程命名并绑定日志上下文
这一步不直接记录异常，但为后续精准归因打下基础。给每个线程赋予可识别的名字（如 worker-pool-1-task-5），并在日志中自动携带该名称：
public class LoggingThreadFactory implements ThreadFactory {
private final AtomicInteger threadNumber = new AtomicInteger(1);
private final String poolName;
<pre class="brush:php;toolbar:false;">public LoggingThreadFactory(String poolName) {
this.poolName = poolName;
}
@Override
public Thread newThread(Runnable r) {
Thread t = new Thread(r, poolName + "-thread-" + threadNumber.getAndIncrement());
// 可选：设置 UncaughtExceptionHandler，作为兜底（但无法获取任务信息）
t.setUncaughtExceptionHandler((thread, ex) ->
log.error("Uncaught exception in thread {}", thread.getName(), ex)
);
return t;
}}
2. 包装任务：在 Runnable/Callable 执行前后统一捕获异常
真正记录详细日志的核心逻辑在这里。不要依赖线程级异常处理器，而是把原始任务包装一层，在 run() 或 call() 内部做 try-catch，并记录上下文信息：
立即学习“Java免费学习笔记（深入）”；
JavaStoryDevelop
下载
你接手一个需求时，是不是经常这样："改一个小字段 → 结果把不相关的代码也改了"、"需求说得很模糊 → 做着做着发现跑偏了"、"数据库加个字段 → 上线才发现漏了数据兼容"、"做了个新功能 → 一个月后自己都忘了当时怎么设计的"、"写到一半被中断 → 再回来不知道从哪继续"；这个 Skill 就是专门解决这些问题的。 它会自动探测你的项目环境（JDK、Spring Boot、ORM、数据库、前端框架），记在
public class LoggingRunnable implements Runnable {
private final Runnable task;
private final String taskName; // 如 "OrderTimeoutHandler#process"
private final Logger log = LoggerFactory.getLogger(LoggingRunnable.class);
<pre class="brush:php;toolbar:false;">public LoggingRunnable(Runnable task, String taskName) {
this.task = task;
this.taskName = taskName;
}
@Override
public void run() {
long start = System.currentTimeMillis();
String threadName = Thread.currentThread().getName();
try {
log.debug("Starting task '{}' on thread '{}'", taskName, threadName);
task.run();
log.debug("Completed task '{}' on thread '{}' (took {}ms)",
taskName, threadName, System.currentTimeMillis() - start);
} catch (Throwable ex) {
// 记录完整上下文：任务名、线程名、时间、堆栈、甚至可序列化的任务状态（如果 task 支持）
log.error("Task '{}' failed on thread '{}' at {}",
taskName, threadName, new Date(), ex);
throw ex; // 保持原有异常传播行为（尤其对 submit(Callable) 的 Future.get() 重要）
}
}}
使用时这样提交：
ExecutorService pool = new ThreadPoolExecutor(
2, 4, 60L, TimeUnit.SECONDS,
new LinkedBlockingQueue<>(),
new LoggingThreadFactory("order-process")
);
<p>// 包装后提交
pool.submit(new LoggingRunnable(() -> {
// 实际业务逻辑，可能抛 RuntimeException
processOrder(orderId);
}, "OrderProcessor#processOrder"));3. 进阶：用装饰器模式统一拦截所有提交的任务
避免每次手动包装，可以扩展 ThreadPoolExecutor，重写 execute() 和 submit() 方法，自动完成包装：
public class LoggingThreadPoolExecutor extends ThreadPoolExecutor {
private final Logger log = LoggerFactory.getLogger(getClass());
<pre class="brush:php;toolbar:false;">public LoggingThreadPoolExecutor(int corePoolSize, int maxPoolSize,
long keepAliveTime, TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory) {
super(corePoolSize, maxPoolSize, keepAliveTime, unit, workQueue, threadFactory);
}
@Override
public void execute(Runnable command) {
super.execute(wrap(command, "anonymous"));
}
@Override
public Future<?> submit(Runnable task) {
return super.submit(wrap(task, "submitted-runnable"));
}
@Override
public <T> Future<T> submit(Callable<T> task) {
return super.submit(wrap(task, "submitted-callable"));
}
private Runnable wrap(Runnable task, String defaultName) {
String name = extractTaskName(task);
return new LoggingRunnable(task, name);
}
private <T> Callable<T> wrap(Callable<T> task, String defaultName) {
String name = extractTaskName(task);
return () -> {
long start = System.currentTimeMillis();
String threadName = Thread.currentThread().getName();
try {
log.debug("Starting callable '{}' on thread '{}'", name, threadName);
T result = task.call();
log.debug("Completed callable '{}' on thread '{}' (took {}ms)",
name, threadName, System.currentTimeMillis() - start);
return result;
} catch (Exception ex) {
log.error("Callable '{}' failed on thread '{}' at {}", name, threadName, new Date(), ex);
throw ex;
}
};
}
private String extractTaskName(Object task) {
if (task instanceof NamedTask) {
return ((NamedTask) task).getTaskName();
}
return task.getClass().getSimpleName();
}}
这样使用者无需关心包装，直接 submit(runnable) 即可获得全量日志。
4. 补充建议：增强可观测性
-
加入 MDC（Mapped Diagnostic Context）：在
LoggingRunnable的run()开头调用MDC.put("taskId", UUID.randomUUID().toString())，让同一次任务的所有日志自动带上唯一 ID，方便链路追踪。 -
记录任务入队时间：在包装时记录
System.nanoTime()，在执行前计算排队耗时，辅助性能分析。 - 避免日志爆炸：对高频任务，可对异常做限流（如每分钟最多记录 5 次同类异常），或只记录 ERROR 级别异常，WARN 级别做聚合统计。
