一、为什么要用线程池
在开发过程中，如果需要经常使用new Thread来处理相关任务。线程的频繁新建与销毁需要很大的开销，如何高效利用多线程处理任务，这时候就需要线程池来做管理了。线程池保证了线程高效的重复利用性。
二、线程池使用流程
1、线程池构造函数
线程池创建通过线程池构造函数完成，最全的构造函数如下图1：
图1
corePoolSize：核心线程数
maximumPoolSize：最大线程数
keepAliveTime：线程存活时间
unit：线程存活时间单位
workQueue：阻塞队列
threadFactory：线程创建工厂
handler：线程丢弃策略实现
在线程池逻辑中，maximumPoolSize一定要大于等于corePoolSize，线程存活时间要大于0，阻塞队列、线程创建工厂、线程丢弃策略实现等不能为空
2、线程池执行流程
线程池执行提交任务，调用execute方法，源码如下图2所示
图2
整个流程如下图3
图3
如何新建线程，并且去运行，通过addWorker方法实现，源码如下：
图4
一开始进入一个for死循坏，获取当前线程池状态，线程池一共有5个状态，RUNNING（-1）、SHUTDOWN（0）、STOP（1）、TIDYING（2）、TERMINATED（3）。
if (rs >=SHUTDOWN && ! (rs ==SHUTDOWN && firstTask ==null && !workQueue.isEmpty()))
return false;
该段代码的意思是当线程池状态不是RUNNING态且以下条件有一个不满足的i情况下
1、当状态为SHUTDOWN状态
2、提交的任务为空
3、当前阻塞队列不为空
新建线程失败，总结为如果当前线程态为STOP、TIDYING、TERMINATED态时，表明线程池已经关闭，不能再启动任务；当线程池态为SHUTDOWN状态，且不是提交新任务（firstTask ==null），且阻塞队列不为空的话，会新建线程去执行阻塞队列里面的任务
当没有return false，此时会进入下一个死循环，拿到当前线程池里面的线程数量，如果是新建核心线程的话，判断当前线程数量是否大于核心线程数量，大于的话，直接return false；如果是新建非核心线程的话，判断当前线程数量是否大于最大线程数量，大于的话，直接return false；以上未return false的话，会去增加线程数，当增加成功的话，直接跳出里外两个循环，否则的话再次获取当前线程的状态，如果与外层for循环获取的状态不相等的话会跳出内存循环，否则继续内存循环
当跳出循环未return 后，表明线程数增加成功，此时再去新建新的线程，并启用该线程
看到这，关于线程池如何新建核心、非核心线程已经很清楚了，但关于线程池如何复用还一直没看到，该思想隐藏在新建Worker类线程的启动里面，具体实现方法为runWorker，源码如下图5
图5
除了当前task被执行外，还会去阻塞队列中去取（getTask），如下图所示，这样就实现了线程的高效复用
图6
关于核心线程如何一直存活及如果设置了核心线程也可以超时死亡的话是如何实现的呢
boolean timed =allowCoreThreadTimeOut || wc >corePoolSize; 判断线程是否可以超时死亡，当timed为false时orkQueue.take()执行take方法，以ArrayBlockingQueue为例
图7
可以看出，当数量为0时，线程会等待，这样就避免线程死亡了
而当可以超时死亡时，执行workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS)
图8
可以看出当队列任务为0时，会有个等待超时锁，当时间到时返回null，线程结束
网友评论