concurrent包下线程池类小结
并发包下的线程池技术虽然常用,但是知识点较多易忘。所以,参考网络资源做了一个小结,便于复习。
1.Executor接口
用于执行已提交的Runnable任务。
![](https://img.haomeiwen.com/i2616609/7a8d67841817974f.png)
2.ExecutorService接口
继承自Executor接口。
![](https://img.haomeiwen.com/i2616609/14261c2c21b8a13d.png)
3.ScheduledExecutorService接口
继承自ExecutorService接口,在给定的延迟后执行任务或定时执行任务,类图如下。
![](https://img.haomeiwen.com/i2616609/ffefc784efc30c28.png)
![](https://img.haomeiwen.com/i2616609/8aa3a66433eb9fa7.png)
4.RejectedExecutionHandler接口
当Executor已经关闭或任务队列已经饱和时,提交新任务时,Executor对应的处理策略。
![](https://img.haomeiwen.com/i2616609/2ac96fda7149b2de.png)
5.RejectedExecutionHandler接口实现类
RejectedExecutionHandler接口4个实现类对应4种处理策略:
![](https://img.haomeiwen.com/i2616609/d911677d2c6f49f1.png)
6.BlockingQueue接口
BlockingQueue接口定义任务队列。
![](https://img.haomeiwen.com/i2616609/fa45cee2efb5220b.png)
7.ArrayBlockingQueue类
实现了BlockingQueue接口。一个由数组支持的有界阻塞队列。此队列按 FIFO(先进先出)原则对元素进行排序。队列的头部是在队列中存在时间最长的元素。队列的尾部是在队列中存在时间最短的元素。新元素插入到队列的尾部,队列获取操作则是从队列头部开始获得元素。类图如下图所示。
![](https://img.haomeiwen.com/i2616609/2d7d53954eb55b11.png)
![](https://img.haomeiwen.com/i2616609/e92333b9163c7a96.png)
![](https://img.haomeiwen.com/i2616609/b8828bde03ae8558.png)
8.Executors类
为ExecutorService、ScheduledExecutorService、ThreadFactory和Callable提供了便捷的工厂方法。
此类支持以下各种方法:
* 创建并返回设置有常用配置字符串的 ExecutorService 的方法。
* 创建并返回设置有常用配置字符串的 ScheduledExecutorService 的方法。
* 创建并返回“包装的”ExecutorService 方法,它通过使特定于实现的方法不可访问来禁用重新配置。
* 创建并返回 ThreadFactory 的方法,它可将新创建的线程设置为已知的状态。
* 创建并返回非闭包形式的 Callable 的方法,这样可将其用于需要 Callable 的执行方法中。
![](https://img.haomeiwen.com/i2616609/7201c94104710586.png)
9.ThreadPoolExecutor类
类图如下图所示。
![](https://img.haomeiwen.com/i2616609/87e3f3aa43db152b.png)
ThreadPoolExecutor使用Executors工厂方法Executors.newCachedThreadPool()(无界线程池,可以进行自动线程回收)、Executors.newFixedThreadPool(int)(固定大小线程池)和 Executors.newSingleThreadExecutor()(单个后台线程)配置的线程池执行每个提交的任务。
![](https://img.haomeiwen.com/i2616609/5ee9850289e8ea42.png)
使用构造方法可以创建一个自定义的线程池。ThreadPoolExecutor将根据corePoolSize和maximumPoolSize设置的边界自动调整池大小。当新任务在方法execute(java.lang.Runnable) 中提交时,如果运行的线程少于corePoolSize,则创建新线程来处理请求,即使其他辅助线程是空闲的。如果运行的线程多于corePoolSize而少于 maximumPoolSize,则仅当队列满时才创建新线程。如果设置的corePoolSize和maximumPoolSize相同,则创建了固定大小的线程池。如果将 maximumPoolSize 设置为基本的无界值(如Integer.MAX_VALUE),则允许池适应任意数量的并发任务。在大多数情况下,核心和最大池大小仅基于构造来设置,不过也可以使用setCorePoolSize(int)和 setMaximumPoolSize(int)进行动态更改。所有BlockingQueue都可用于传输和保持提交的任务。可以使用此队列与池大小进行交互:
* 如果运行的线程少于corePoolSize,则Executor始终首选添加新的线程,而不进行排队。
* 如果运行的线程等于或多于corePoolSize,则Executor始终首选将请求加入队列,而不添加新的线程。
* 如果无法将请求加入队列,则创建新的线程,除非创建此线程超出maximumPoolSize,在这种情况下,任务将被拒绝。
10.ScheduledThreadPoolExecutor类
实现了ScheduledExecutorService接口,在给定的延迟后执行任务,或者定时执行任务,按照提交的先进先出(FIFO)顺序来启用那些被安排在同一执行时间的任务。类图如下所示。
![](https://img.haomeiwen.com/i2616609/9207c3e7bdf449bf.png)
虽然此类继承自ThreadPoolExecutor,但是几个继承的调整方法对此类并无作用。特别是,因为它作为一个使用corePoolSize 线程和一个无界队列的固定大小的池,所以调整maximumPoolSize没有什么效果。
![](https://img.haomeiwen.com/i2616609/1afb9681880c548f.png)
![](https://img.haomeiwen.com/i2616609/308c3f9289780ac5.png)