自定义ThreadFactory命名线程是提升Java线程池可观测性的最简有效手段，通过{模块}-{功能}-{序号}格式（如payment-sender-1）并动态追加状态后缀（如-idle），结合AtomicInteger防重名、beforeExecute/afterExecute动态更新名称，配合ThreadMXBean实时监控线程状态。
直接用自定义 ThreadFactory 给线程起名，是 Java 线程池最简单、最有效的可观察性增强手段。名字一加，线程 dump 里不再全是 pool-1-thread-1 这种“代号”，而是清晰可见的业务语义（如 order-processor-1）；配合 JMX 或简单的定时巡检，还能实时知道哪些线程卡住、哪些已退出、哪些长期空闲——这对排查死锁、泄漏、响应延迟至关重要。
命名规则要带业务上下文 + 序号 + 可选状态标识
光叫 worker-1 没意义，得让人一眼看出“谁在干什么”。推荐格式：{模块}-{功能}-{序号}[-{状态}]，例如：
-
payment-sender-1：支付模块的消息发送线程 -
report-generator-3-idle：报表生成线程池中第 3 号空闲线程（运行时动态追加） -
cache-loader-2-active：缓存预热线程，当前正执行任务
关键点：序号必须原子递增（用 AtomicInteger），避免重名；状态后缀建议在 beforeExecute/afterExecute 中动态修改（需用 Thread.setName() 覆盖原名）。
实现线程工厂：封装命名逻辑与线程属性
不要裸写匿名类。封装成可复用的工厂类，支持传入前缀、是否启用状态标记、是否设置守护线程等：
public class NamedThreadFactory implements ThreadFactory {
private final String prefix;
private final AtomicInteger threadNumber = new AtomicInteger(1);
private final boolean daemon;
private final boolean trackStatus;
public NamedThreadFactory(String prefix, boolean daemon, boolean trackStatus) {
this.prefix = prefix;
this.daemon = daemon;
this.trackStatus = trackStatus;
}
@Override
public Thread newThread(Runnable r) {
Thread t = new Thread(r, prefix + "-" + threadNumber.getAndIncrement());
t.setDaemon(daemon);
t.setUncaughtExceptionHandler((thread, ex) ->
System.err.println("Uncaught in " + thread.getName() + ": " + ex));
return t;
}
}
使用时直接传入业务标识：
ExecutorService executor = new ThreadPoolExecutor(
4, 8, 60, TimeUnit.SECONDS,
new LinkedBlockingQueue<>(100),
new NamedThreadFactory("inventory-checker", false, true),
new ThreadPoolExecutor.CallerRunsPolicy()
);
监控存活状态：不依赖外部框架，纯 JDK 就能做
Java 自带 ThreadMXBean 可实时查所有线程状态。结合线程名过滤，5 行代码就能统计你关心的线程：
ThreadMXBean bean = ManagementFactory.getThreadMXBean();
long[] ids = bean.getAllThreadIds();
ThreadInfo[] infos = bean.getThreadInfo(ids, 0); // 0 表示不采集栈帧，轻量
long active = Arrays.stream(infos)
.filter(ti -> ti != null && ti.getThreadName().startsWith("payment-sender-"))
.filter(ti -> ti.getThreadState() == Thread.State.RUNNABLE ||
ti.getThreadState() == Thread.State.TIMED_WAITING)
.count();
System.out.println("payment-sender active: " + active);
进阶技巧：
- 用
ScheduledExecutorService每 10 秒跑一次上述逻辑，把结果打到日志或上报 Prometheus - 发现某线程长时间处于
WAITING且栈顶是Object.wait()或LockSupport.park()，大概率卡在锁或队列上 - 发现
inventory-checker-5名字还在但ThreadInfo为null？说明该线程已终止，但线程池没及时回收（可能是 corePoolSize 设置过大）
实战避坑：命名不是万能的，状态需动态刷新
静态命名只是起点。线程生命周期中状态会变，而 Thread.setName() 是唯一能改名的 API —— 必须主动调用：
- 在线程池的
beforeExecute回调里设为-active后缀 - 在
afterExecute里恢复为-idle或清除后缀 - 若用
ThreadPoolExecutor子类，重写这两个方法；若用Executors工具类创建，则需包装Runnable或借助 AOP
注意：Thread.setName() 不影响线程 ID 或堆栈，只改显示名，安全无副作用。
