就是一种池化技术,类似的还有jdbc连接池,对象池。所谓线程池,就是提前创建一堆线程,放到内存(池子)中,需要的时候取一个出来用。
如上图,最顶层的接口就是Executor,实现ExecutorService接口的类,就是对应的线程池类。
用Executors工具类,可以很方便地创建各种线程池。(但是实际开发我们不推荐,阿里巴巴的开发手册严令禁止使用Executors,应该用ThreadPoolExecutor)Executors 类可以创建多种类型的线程池,每种线程池都有不同的特点和适用场景。
(1) FixedThreadPool(固定大小线程池):
(2) CachedThreadPool(缓存线程池):
(3) SingleThreadPool(单线程线程池):
(4) ScheduledThreadPool(定时任务线程池):
(5) WorkStealingPool(工作窃取线程池):
为什么不推荐用Executors创建?
我们以ThreadPoolExecutor为例,它是ExecutorService的一种实现。
一般我们根据一个类的构造器,可以看出里面的大致思路:
public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler) { if (corePoolSize < 0 || maximumPoolSize <= 0 || maximumPoolSize < corePoolSize || keepAliveTime < 0) throw new IllegalArgumentException(); if (workQueue == null || threadFactory == null || handler == null) throw new NullPointerException(); this.corePoolSize = corePoolSize; this.maximumPoolSize = maximumPoolSize; this.workQueue = workQueue; this.keepAliveTime = unit.toNanos(keepAliveTime); this.threadFactory = threadFactory; this.handler = handler; }
参数很多,但是我们每一个都必须要记住。 这个 ThreadPoolExecutor 的构造函数接受以下参数:一个线程池就好比一家公司,甲方员工干不完需求的时候,就要招一些外包人员驻场开发,如果活干完了,就让外包撤场,只留下自己的员工。
这些参数可以用于配置 ThreadPoolExecutor 对象,以满足不同的线程管理需求。
线程池本质就是一个HashSet,所以是无序的。有新的任务提交进来,如果池子还有线程,就直接拿去处理,池子满了就放入阻塞队列,等待有线程空闲。
这个是没有银弹的,我们一般认为CPU密集型的应用,设置为CPU核数N+1。所谓CPU密集型,就是这个程序计算量比较多,还比较频繁,计算时间长,也就是所谓的比较吃配置,比如是一个专门做算法的服务(组托,配载运算之类的)。
对于IO密集型的应用,设置为2N+1,什么是IO密集型的应用呢,就是提供数据服务比较多,吞吐量比较大,等待时间长的应用,大部分业务系统都属于此类。
除此之外,线程数还跟jvm,机器cpu是否可以超线程(云服务器一般没法超线程),我们看到的cpu核数一般不是真实的,所以我们推荐先根据常规设置一个线程数量,上线后根据具体情况再调整就行了。
本文链接:http://www.28at.com/showinfo-26-80831-0.html面试官:听说你很懂线程池?
声明:本网页内容旨在传播知识,若有侵权等问题请及时与本网联系,我们将在第一时间删除处理。邮件:2376512515@qq.com
上一篇: 千人规模敏捷迭代实践分享,你学会了吗?