[java]
class SimpleThreadFactory implements ThreadFactory {
@Override
public Thread newThread(Runnable r) {
return new Thread(r);
}
}
如果我们在使用executors工具类创建具体的executor时,如果没有显式告诉自定义的ThreadFactory时,则使用默认的线程工厂:
[java]
static class DefaultThreadFactory implements ThreadFactory {
private static final AtomicInteger poolNumber = new AtomicInteger(1);
private final ThreadGroup group;
private final AtomicInteger threadNumber = new AtomicInteger(1);
private final String namePrefix;
DefaultThreadFactory() {
SecurityManager s = System.getSecurityManager();
group = (s != null) s.getThreadGroup() :
Thread.currentThread().getThreadGroup();
namePrefix = "pool-" +
poolNumber.getAndIncrement() +
"-thread-";
}
public Thread newThread(Runnable r) {
Thread t = new Thread(group, r,
namePrefix + threadNumber.getAndIncrement(),
0);
if (t.isDaemon())
t.setDaemon(false);
if (t.getPriority() != Thread.NORM_PRIORITY)
t.setPriority(Thread.NORM_PRIORITY);
return t; www.2cto.com
}
}
如果想自定义线程工厂,则需提供一个实现了ThreadFactory的类(如上面的SimpleThreadFactory),然后当我们创建具体的executor时:
[java]
ExecutorService executor = Executors.newCachedThreadPool(new SimpleThreadFactory());
ExecutorService executor = Executors.newSingleThreadExecutor(new SimpleThreadFactory());
ExecutorService executor = Executors.newFixedThreadPool(10, new SimpleThreadFactory());
ExecutorService executor = Executors.newScheduledThreadPool(10, new SimpleThreadFactory());
这样,就会使用自定义的线程工厂来创建线程。