java中ThreadPoolExecutor常识汇总

线程池技术在并发时经常会使用到，java中的线程池的使用是通过调用threadpoolexecutor来实现的。threadpoolexecutor提供了四个构造函数,最后都会归结于下面这个构造方法：

// 七个参数的构造函数
public threadpoolexecutor(int corepoolsize,
int maximumpoolsize,
long keepalivetime,
timeunit unit,
blockingqueue<runnable> workqueue,
threadfactory threadfactory,
rejectedexecutionhandler handler)

这些参数的意义如下：

• corepoolsize：该线程池中核心线程数最大值
• maximumpoolsize： 该线程池中线程总数最大值
• keepalivetime：该线程池中非核心线程闲置超时时长
• unit：keepalivetime的单位
• workqueue：阻塞队列blockingqueue，维护着等待执行的runnable对象
• threadfactory：创建线程的接口，需要实现他的thread newthread(runnable r)方法。
• rejectedexecutionhandler：饱和策略，最大线程和工作队列容量且已经饱和时execute方法都将调用rejectedexecutionhandler 。

threadpoolexecutor工作流程

流程图如下：

大致过程陈述为：

1. 向线程池中添加任务，当任务数量少于corepoolsize时，会自动创建thead来处理这些任务；
2. 当添加任务数大于corepoolsize且少于maximmpoolsize时，不在创建线程，而是将这些任务放到阻塞队列中，等待被执行；
3. 接上面2的条件，且当阻塞队列满了之后，继续创建thread,从而加速处理阻塞队列；
4. 当添加任务大于maximmpoolsize时，根据饱和策略决定是否容许继续向线程池中添加任务，默认的饱和策略是abortpolicy（直接丢弃）。

线程池中使用的阻塞队列

• arrayblockingqueue：基于数组结构的有界阻塞队列，构造函数一定要传大小，fifo（先进先出）；
• linkedblockingqueue：*，默认大小65536（integer.max_value），当大量请求任务时，容易造成内存耗尽。
• synchronousqueue：同步队列，是一个特殊的blockingqueue，它没有容量（这是因为在synchronousqueue中，插入将等待另一个线程的删除操作，反之亦然）。具体可以参考：《java synchronousqueue examples（译）》
• priorityblockingqueue: 优先队列，*。
• delayedworkqueue：这个队列接收到任务时，首先先入队，只有达到了指定的延时时间，才会执行任务

阻塞队列常见的方法如下表所示：

方法名	说明	注意
add	增加一个元索	如果队列已满，则抛出一个iiiegaislabeepeplian异常
remove	移除并返回队列头部的元素	如果队列为空，则抛出一个nosuchelementexception异常
element	返回队列头部的元素	如果队列为空，则抛出一个nosuchelementexception异常
offer	添加一个元素并返回true	如果队列已满，则返回false
poll	移除并返问队列头部的元素	如果队列为空，则返回null
peek	返回队列头部的元素	如果队列为空，则返回null
put	添加一个元素	如果队列满，则阻塞
take	移除并返回队列头部的元素	如果队列为空，则阻塞

常见四种线程池

• newcachedthreadpool
• newfixedthreadpool
• newsinglethreadexecutor
• newscheduledthreadpool

线程池	使用的阻塞队列	线程池大小	超时
cachedthreadpool	synchronousqueue（队列长度无限	可增加，最大值integer.max_value	默认60秒超时
fixedthreadpool	linkedblockingqueue（队列长度无限）	可指定nthreads，固定数量	不会超时
newsinglethreadexecutor	linkedblockingqueue（队列长度无限），	固定为1	不超时
newscheduledthreadpool	delayedworkqueue	可增加，最大值integer.max_value	不超时

它们通过executors以静态方法的方式直接调用，实质上是它们最终调用的是threadpoolexecutor的构造方法，也就是本文最前面那段代码。

注：keepalivetime=0的话，表示不等待

《阿里巴巴java开发手册》中建议线程池不使用 executors 去创建，而是通过 threadpoolexecutor的方式，这样的处理方式让写的人员更加明确线程池的运行规则，规避资源耗尽的风险。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。