第8章 Java并发包中线程池ThreadPoolExecutor原理探究

àì夳堔傛蜴生んèń 2023-02-18 06:27 128阅读 0赞

#### 8.1 介绍 ####

**线程池主要解决两个问题**：

*  **一是当执行大量异步任务时线程池能够提供较好的性能**。在不使用线程池时，每当需要执行异步任务时直接new一个线程来运行，而**线程的创建和销毁是需要开销的。线程池里面的线程是可复用的，不需要每次执行异步任务时都重新创建和销毁线程**。
 *  **二是线程池提供了一种资源限制和管理的手段，比如可以限制线程的个数，动态新增线程等**。每个ThreadPoolExecutor也保留了一些基本的统计数据，比如当前线程池完成的任务数目等。

另外，线程池也提供了许多可调参数和可扩展性接口，以满足不同情境的需要，程序员可以使用更方便的Executors的工厂方法，比如newCachedThreadPool（线程池线程个数最多可达Integer.MAX\_VALUE，线程自动回收）、newFixedThreadPool（固定大小的线程池）和newSingleThreadExecutor（单个线程）等来创建线程池，当然用户还可以自定义。

#### 8.2 类图介绍 ####

![format_png][]

`Executors`其实是个工具类，里面提供了好多静态方法，这些方法根据用户选择返回不同的线程池实例。`ThreadPoolExecutor`继承了`AbstractExecutorService`，

成员变量`ctl`是一个Integer的原子变量，用来记录线程池状态和线程池中线程个数，类似于ReentrantReadWriteLock使用一个变量来保存两种信息。这里假设Integer类型是32位二进制表示，则其中高3位用来表示线程池状态，后面29位用来记录线程池线程个数。

`mainLock`是独占锁，用来控制新增Worker线程操作的原子性。

`termination`是该锁对应的条件队列，在线程调用awaitTermination时用来存放阻塞的线程。

**`Worker`继承`AQS`和`Runnable`接口，是具体承载任务的对象**。Worker继承了AQS，自己实现了简单不可重入独占锁，其中state=0表示锁未被获取状态，state=1表示锁已经被获取的状态，state=-1是创建Worker时默认的状态，创建时状态设置为-1是为了避免该线程在运行runWorker（）方法前被中断。其中变量`firstTask`记录该工作线程执行的第一个任务，`thread`是具体执行任务的线程。

`DefaultThreadFactory`是线程工厂，`newThread()`方法是对线程的一个修饰。其中`poolNumber`是个静态的原子变量，用来统计线程工厂的个数，`threadNumber`用来记录每个线程工厂创建了多少线程，这两个值也作为线程池和线程的名称的一部分。

**线程池状态含义如下**：

*  `RUNNING`：接受新任务并且处理阻塞队列里的任务。
 *  `SHUTDOWN`：拒绝新任务但是处理阻塞队列里的任务。
 *  `STOP`：拒绝新任务并且抛弃阻塞队列里的任务，同时会中断正在处理的任务。
 *  `TIDYING`：所有任务都执行完（包含阻塞队列里面的任务）后当前线程池活动线程数为0，将要调用terminated方法。
 *  `TERMINATED`：终止状态。terminated方法调用完成以后的状态。

**线程池状态转换列举如下**：

*  `RUNNING -> SHUTDOWN` ：显式调用shutdown（）方法，或者隐式调用了finalize（）方法里面的shutdown（）方法。
 *  `RUNNING或SHUTDOWN -> STOP` ：显式调用shutdownNow（）方法时。
 *  `SHUTDOWN -> TIDYING` ：当线程池和任务队列都为空时。
 *  `STOP -> TIDYING` ：当线程池为空时。
 *  `TIDYING -> TERMINATED`：当terminated（）hook方法执行完成时。

**线程池参数如下**：

*  `corePoolSize`：线程池核心线程个数。
 *  `workQueue`：用于保存等待执行的任务的阻塞队列，比如基于数组的有界ArrayBlockingQueue、基于链表的无界LinkedBlockingQueue、最多只有一个元素的同步队列SynchronousQueue及优先级队列PriorityBlockingQueue等。
 *  `maximunPoolSize`：线程池最大线程数量。
 *  `ThreadFactory`：创建线程的工厂。
 *  `RejectedExecutionHandler`：饱和策略，当队列满并且线程个数达到maximunPoolSize后采取的策略，比如AbortPolicy（抛出异常）、CallerRunsPolicy（使用调用者所在线程来运行任务）、DiscardOldestPolicy（调用poll丢弃一个任务，执行当前任务）及DiscardPolicy（默默丢弃，不抛出异常）
 *  `keeyAliveTime`：存活时间。如果当前线程池中的线程数量比核心线程数量多，并且是闲置状态，则这些闲置的线程能存活的最大时间。
 *  `TimeUnit`：存活时间的时间单位。

**线程池类型如下**：

*  `newFixedThreadPool` ：创建一个核心线程个数和最大线程个数都为nThreads的线程池，并且阻塞队列长度为Integer.MAX\_VALUE。keeyAliveTime=0说明只要线程个数比核心线程个数多并且当前空闲则回收。
 *  `newSingleThreadExecutor`：创建一个核心线程个数和最大线程个数都为1的线程池，并且阻塞队列长度为Integer.MAX\_VALUE。keeyAliveTime=0说明只要线程个数比核心线程个数多并且当前空闲则回收。
 *  `newCachedThreadPool` ：创建一个按需创建线程的线程池，初始线程个数为0，最多线程个数为Integer.MAX\_VALUE，并且阻塞队列为同步队列。keeyAliveTime=60说明只要当前线程在60s内空闲则回收。这个类型的特殊之处在于，加入同步队列的任务会被马上执行，同步队列里面最多只有一个任务。

#### 8.3 源码分析 ####

##### 8.3.1 public void execute(Runnable command) #####

**execute方法的作用是提交任务command到线程池进行执行**。用户线程提交任务到线程池的模型图如下图所示。

![format_png 1][]

从该图可以看出，**ThreadPoolExecutor的实现实际是一个生产消费模型，当用户添加任务到线程池时相当于生产者生产元素，workers线程工作集中的线程直接执行任务或者从任务队列里面获取任务时则相当于消费者消费元素**。

**该方法主要做了两件事**：

*  通过CAS操作增加线程数；
 *  把并发安全的任务添加到workers里面并且启动任务执行或将任务添加到队列中等待取出然后启动任务执行。

##### 8.3.2 工作线程Worker的执行 #####

用户线程提交任务到线程池后，由Worker来执行。

##### 8.3.3 shutdown操作 #####

调用shutdown方法后，线程池就不会再接受新的任务了，但是工作队列里面的任务还是要执行的。该方法会立刻返回，并不等待队列任务完成再返回。

##### 8.3.4 shutdownNow操作 #####

调用shutdownNow方法后，线程池就不会再接受新的任务了，并且会丢弃工作队列里面的任务，正在执行的任务会被中断，该方法会立刻返回，并不等待激活的任务执行完成。返回值为这时候队列里面被丢弃的任务列表。

##### 8.4 总结 #####

**线程池巧妙地使用一个Integer类型的原子变量来记录线程池状态和线程池中的线程个数。通过线程池状态来控制任务的执行，每个Worker线程可以处理多个任务。线程池通过线程的复用减少了线程创建和销毁的开销。**

[format_png]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9ub3RlLnlvdWRhby5jb20veXdzL3B1YmxpYy9yZXNvdXJjZS9lNzRiYjQwMTllNjM1NWE3NzQ1YWE0ZGUwNjEwOTBiZi94bWxub3RlL1dFQlJFU09VUkNFMzM3M2U4MmE5YWZkNTg5ZjdmNTJjYjljOWMyMzgyNzMvMzc2NTQ?x-oss-process=image/format,png
[format_png 1]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9ub3RlLnlvdWRhby5jb20veXdzL3B1YmxpYy9yZXNvdXJjZS9lNzRiYjQwMTllNjM1NWE3NzQ1YWE0ZGUwNjEwOTBiZi94bWxub3RlL1dFQlJFU09VUkNFOWRmYjg3ZmY0NDI4YjlkMzFmMzE5MDZlYWI1YTI4MTAvMzc2NjY?x-oss-process=image/format,png