线程工厂是threadpoolexecutor构造参数之一，负责创建新线程，影响可识别性、可观测性和运行时行为；需自定义以提供有意义前缀、自动编号、非守护线程、正确上下文类加载器等关键要素。
为什么不能只用 Executors.defaultThreadFactory()
默认线程工厂创建的线程名称形如 pool-1-thread-1，缺乏业务语义。在微服务或高并发系统中，多个模块共用线程池时，日志、堆栈、JVM 线程 dump 中无法快速定位线程归属；也无法统一设置守护线程、优先级或上下文类加载器。更严重的是，若未显式指定线程工厂，所有线程都共享主线程的上下文类加载器，可能引发类泄漏或 ClassLoader 不一致问题。
如何自定义线程工厂：关键要素
实现 ThreadFactory 接口只需重写 newThread(Runnable r) 方法，但生产环境建议包含以下要素：
-
有意义的线程名前缀：例如
"order-service-worker"或"cache-refresh-pool"，便于日志过滤与监控归类 - 自动编号：避免重复命名，可用 AtomicInteger 实现递增序号
- 设置为非守护线程（除非明确需要）：防止 JVM 退出时线程被意外终止
-
指定合适的线程优先级：通常保持
Thread.NORM_PRIORITY，避免干扰关键调度 - 绑定当前上下文类加载器：确保线程执行任务时能正确加载业务类
推荐写法：轻量且健壮的线程工厂
以下是一个通用、线程安全、带业务标识的实现示例：
public class NamedThreadFactory implements ThreadFactory {
private final String prefix;
private final AtomicInteger threadNumber = new AtomicInteger(1);
private final boolean daemon;
public NamedThreadFactory(String prefix) {
this(prefix, false);
}
public NamedThreadFactory(String prefix, boolean daemon) {
this.prefix = prefix;
this.daemon = daemon;
}
@Override
public Thread newThread(Runnable r) {
Thread t = new Thread(r, prefix + "-thread-" + threadNumber.getAndIncrement());
t.setDaemon(daemon);
t.setContextClassLoader(Thread.currentThread().getContextClassLoader());
return t;
}
}
使用时直接传入：
ThreadPoolExecutor executor = new ThreadPoolExecutor(
4, 8, 60L, TimeUnit.SECONDS,
new ArrayBlockingQueue(100),
new NamedThreadFactory("payment-async"),
new ThreadPoolExecutor.AbortPolicy()
);
进阶实践：结合 MDC 或 TraceID 的线程复用支持
在分布式链路追踪场景下，线程可能跨任务复用，导致 MDC（Mapped Diagnostic Context）内容残留。虽然线程工厂本身不处理 MDC 清理，但可配合 ThreadLocal 初始化或任务包装器统一处理。常见做法是在提交任务时封装一层 Runnable/Callable，确保每次执行前清空或继承父上下文 —— 这虽不属于线程工厂职责，却是其上下游协同的关键点。
简言之，线程工厂不是“配角”，而是线程生命周期的第一道入口。它不增加复杂度，却大幅提升系统的可观测性与可维护性。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
