自定义 threadfactory 的核心是创建一个实现 java.lang.threadfactory 接口的类，并重写其唯一的 newthread(runnable r) 方法。在该方法中，你可以实例化一个具体的 thread 对象，设置线程名称、优先级、所属线程组或是否为守护线程，然后返回这个新创建的线程实例。这样，当线程池调用工厂创建线程时，就会使用你定义的逻辑来生成线程。
如何为线程设置唯一且可读的名称
在 newThread 方法中，通过拼接业务标识和计数器来生成线程名是最常见的做法。这有助于在日志和监控中快速定位问题线程。下面是一个完整的示例，展示了如何创建一个带有前缀和递增编号的线程工厂。
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicInteger;
public class CustomThreadFactory implements ThreadFactory {
private final String namePrefix;
private final AtomicInteger threadNumber = new AtomicInteger(1);
public CustomThreadFactory(String namePrefix) {
this.namePrefix = namePrefix + "-thread-";
}
@Override
public Thread newThread(Runnable r) {
Thread t = new Thread(r, namePrefix + threadNumber.getAndIncrement());
System.out.println("Created new thread: " + t.getName());
return t;
}
}运行上述代码并调用 newThread 三次，控制台将输出：
Created new thread: my-pool-thread-1 Created new thread: my-pool-thread-2 Created new thread: my-pool-thread-3
这种命名方式确保了每个线程都有唯一的标识符，便于调试。
立即学习“Java免费学习笔记（深入）”；
如何设置线程的优先级和守护状态
除了命名，还可以在线程创建时调整其优先级和是否为守护线程。守护线程会在所有非守护线程结束后自动退出，适合用于后台清理任务。以下代码展示了如何在 newThread 中设置这些属性。
import java.util.concurrent.ThreadFactory;
public class ConfigurableThreadFactory implements ThreadFactory {
private final int priority;
private final boolean isDaemon;
public ConfigurableThreadFactory(int priority, boolean isDaemon) {
this.priority = priority;
this.isDaemon = isDaemon;
}
@Override
public Thread newThread(Runnable r) {
Thread t = new Thread(r);
t.setPriority(priority);
t.setDaemon(isDaemon);
System.out.println("Thread created with priority: " + priority + ", daemon: " + isDaemon);
return t;
}
}使用此工厂创建的线程将具有指定的优先级和守护状态。例如，创建一个优先级为 Thread.MAX_PRIORITY 且为守护线程的线程：
ConfigurableThreadFactory factory = new ConfigurableThreadFactory(Thread.MAX_PRIORITY, true);
Thread t = factory.newThread(() -> System.out.println("Running..."));
t.start();这将输出：
Thread created with priority: 10, daemon: true
注意：优先级设置依赖于操作系统调度器，实际效果可能因平台而异。
基于程序中某个输入、条件或结果的具体问题
如果 newThread 方法中传入的 Runnable 参数为 null，会发生什么？根据 java.lang.Thread 的源码，构造函数会抛出 NullPointerException。因此，在自定义工厂中，建议对 r 进行非空检查，以避免运行时异常。
import java.util.concurrent.ThreadFactory;
public class SafeThreadFactory implements ThreadFactory {
@Override
public Thread newThread(Runnable r) {
if (r == null) {
throw new IllegalArgumentException("Runnable cannot be null");
}
Thread t = new Thread(r);
return t;
}
}尝试传入 null 将导致 IllegalArgumentException，从而提前暴露错误。
