Java多线程编程之开个工厂造线程

作者: 西魏陶渊明 博客: https://blog.springlearn.cn/

西魏陶渊明 莫笑少年江湖梦,谁不少年梦江湖

线程工厂

线程是Java里面很重要的一个概念,具体体现就是Thread这个类。我们平时最常用的创建线程就是在用Executors来创建线程池。在前面的章节 也可以看到,创建线程池时候有一个入参就是线程工厂,ThreadFactory这个类。那么这个类具体有什么用呢? 其实就是为了统一在创建线程时设置一些参数, 如是否守护线程。线程一些特性等,如优先级,名称。

/**

* @param threadFactory 线程工厂

*/

public ThreadPoolExecutor(int corePoolSize,

int maximumPoolSize,

long keepAliveTime,

TimeUnit unit,

BlockingQueue workQueue,

ThreadFactory threadFactory) {

this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,

threadFactory, defaultHandler);

}

自定义

所谓线程工厂其实就是创建线程使用的。正常情况下我们创建线程是下面这样的。

Thread ret = new Thread(runnable);

但是线程的构造其实并不是只有一个,它有一个线程组的概念,另外也可以给每个线程去设置一个名字。这样的目的是可以通过名字就能辨认是什么线程在执行。

那么我们就看下这里面怎么实现的,其实非常简单。

public class NamedThreadFactory implements ThreadFactory {

protected static final AtomicInteger POOL_SEQ = new AtomicInteger(1);

protected final AtomicInteger mThreadNum = new AtomicInteger(1);

protected final String mPrefix;

protected final boolean mDaemon;

protected final ThreadGroup mGroup;

public NamedThreadFactory() {

this("pool-" + POOL_SEQ.getAndIncrement(), false);

}

public NamedThreadFactory(String prefix) {

this(prefix, false);

}

public NamedThreadFactory(String prefix, boolean daemon) {

mPrefix = prefix + "-thread-";

mDaemon = daemon;

SecurityManager s = System.getSecurityManager();

mGroup = (s == null) ? Thread.currentThread().getThreadGroup() : s.getThreadGroup();

}

@Override

public Thread newThread(Runnable runnable) {

//就是给线程创建了一个名字和指定了一个线程组

String name = mPrefix + mThreadNum.getAndIncrement();

Thread ret = new Thread(mGroup, runnable, name, 0);

ret.setDaemon(mDaemon);

return ret;

}

public ThreadGroup getThreadGroup() {

return mGroup;

}

}

如此而已,线程工厂就是这样。

文章来源: springlearn.blog.csdn.net,作者:西魏陶渊明,版权归原作者所有,如需转载,请联系作者。

原文链接:springlearn.blog.csdn.net/article/details/125824237

随便看看