查看历史文章，请点击上方链接关注公众号。
上节
，我们初步探讨了Java并发包中的任务执行服务，实际中，任务执行服务的主要实现机制是线程池，本节，我们就来探讨线程池。
基本概念
线程池，顾名思义，就是一个线程的池子，里面有若干线程，它们的目的就是执行提交给线程池的任务，执行完一个任务后不会退出，而是继续等待或执行新任务。线程池主要由两个概念组成，一个是
任务队列
，另一个是
工作者线程
，工作者线程主体就是一个循环，循环从队列中接受任务并执行，任务队列保存待执行的任务。
线程池的概念类似于生活中的一些排队场景，比如在火车站排队购票、在医院排队挂号、在银行排队办理业务等，一般都由若干个窗口提供服务，这些服务窗口类似于工作者线程，而队列的概念是类似的，只是，在现实场景中，每个窗口经常有一个单独的队列，这种排队难以公平，随着信息化的发展，越来越多的排队场合使用虚拟的统一队列，一般都是先拿一个排队号，然后按号依次服务。
线程池的优点是显而易见的：
Java并发包中线程池的实现类是ThreadPoolExecutor，它继承自AbstractExecutorService，实现了ExecutorService，基本用法与
上节
介绍的类似，我们就不赘述了。不过，ThreadPoolExecutor有一些重要的参数，理解这些参数对于合理使用线程池非常重要，接来下，我们探讨这些参数。
理解线程池
构造方法
ThreadPoolExecutor有多个构造方法，都需要一些参数，主要构造方法有：
public ThreadPoolExecutor(int
corePoolSize
,
int
maximumPoolSize
,
long
keepAliveTime
,
TimeUnit
unit
,
BlockingQueue
workQueue
)
public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue
workQueue,
ThreadFactory
threadFactory
,
RejectedExecutionHandler
handler
)
第二个构造方法多了两个参数threadFactory和handler，这两个参数一般不需要，第一个构造方法会设置默认值。
参数corePoolSize, maximumPoolSize, keepAliveTime, unit用于控制线程池中线程的个数，workQueue表示任务队列，threadFactory用于对创建的线程进行一些配置，handler表示任务拒绝策略。下面我们再来详细探讨下这些参数。
线程池大小
线程池的大小主要与四个参数有关：
maximumPoolSize表示线程池中的最多线程数，线程的个数会动态变化，但这是最大值，不管有多少任务，都不会创建比这个值大的线程个数。
corePoolSize表示线程池中的核心线程个数，不过，这并不是说，一开始就创建这么多线程，
刚创建一个线程池后，实际上并不会创建任何线程。
一般情况下，有新任务到来的时候，如果当前线程个数小于corePoolSiz，就会创建一个新线程来执行该任务，需要说明的是，
即使其他线程现在也是空闲的，也会创建新线程
。
不过，如果线程个数大于等于corePoolSiz，那就不会立即创建新线程了，它会先尝试排队，
需要强调的是，它是"尝试"排队，而不是"阻塞等待"入队
，如果队列满了或其他原因不能立即入队，它就不会排队，而是检查线程个数是否达到了maximumPoolSize，如果没有，就会继续创建线程，直到线程数达到maximumPoolSize。
keepAliveTime的目的是为了释放多余的线程资源，它表示，当线程池中的线程个数大于corePoolSize时，额外空闲线程的存活时间，也就是说，一个非核心线程，在空闲等待新任务时，会有一个最长等待时间，即keepAliveTime，如果到了时间还是没有新任务，就会被终止。如果该值为0，表示所有线程都不会超时终止。
这几个参数除了可以在构造方法中进行指定外，还可以通过getter/setter方法进行查看和修改。
public void setCorePoolSize(int corePoolSize)
public int getCorePoolSize()
public int getMaximumPoolSize()
public void setMaximumPoolSize(int maximumPoolSize)
public long getKeepAliveTime(TimeUnit unit)
public void setKeepAliveTime(long time, TimeUnit unit)
除了这些静态参数，ThreadPoolExecutor还可以查看关于线程和任务数的一些动态数字：
//返回当前线程个数
public int getPoolSize()
//返回线程池曾经达到过的最大线程个数
public int getLargestPoolSize()
//返回线程池自创建以来所有已完成的任务数
public long getCompletedTaskCount()
//返回所有任务数，包括所有已完成的加上所有排队待执行的
public long getTaskCount()
队列
ThreadPoolExecutor要求的队列类型是阻塞队列BlockingQueue，我们在
76节
介绍过多种BlockingQueue，它们都可以用作线程池的队列，比如：
-
LinkedBlockingQueue：基于链表的阻塞队列，可以指定最大长度，但默认是无界的。
-
ArrayBlockingQueue：基于数组的有界阻塞队列
-
PriorityBlockingQueue：基于堆的无界阻塞优先级队列
-
SynchronousQueue：没有实际存储空间的同步阻塞队列
如果用的是无界队列，
需要强调的是，线程个数最多只能达到corePoolSize，到达corePoolSize后，新的任务总会排队，
参数maximumPoolSize也就没有意义了。
另一面，对于SynchronousQueue，我们知道，它没有实际存储元素的空间，当尝试排队时，只有正好有空闲线程在等待接受任务时，才会入队成功，否则，总是会创建新线程，直到达到maximumPoolSize。
任务拒绝策略
如果队列有界，且maximumPoolSize有限，则当队列排满，线程个数也达到了maximumPoolSize，这时，新任务来了，如何处理呢？此时，会触发线程池的任务拒绝策略。
默认情况下，提交任务的方法如execute/submit/invokeAll等会抛出异常，类型为RejectedExecutionException。
不过，拒绝策略是可以自定义的，ThreadPoolExecutor实现了四种处理方式：
-
ThreadPoolExecutor.AbortPolicy：这就是默认的方式，抛出异常
-
ThreadPoolExecutor.DiscardPolicy：静默处理，忽略新任务，不抛异常，也不执行
-
ThreadPoolExecutor.DiscardOldestPolicy：将等待时间最长的任务扔掉，然后自己排队
-
ThreadPoolExecutor.CallerRunsPolicy：在任务提交者线程中执行任务，而不是交给线程池中的线程执行
它们都是ThreadPoolExecutor的public静态内部类，都实现了RejectedExecutionHandler接口，这个接口的定义为：
public interface RejectedExecutionHandler {
void rejectedExecution(Runnable r, ThreadPoolExecutor executor);
}
当线程池不能接受任务时，调用其拒绝策略的rejectedExecution方法。
拒绝策略可以在构造方法中进行指定，也可以通过如下方法进行指定：
public void setRejectedExecutionHandler(RejectedExecutionHandler handler)
默认的RejectedExecutionHandler是一个AbortPolicy实例，如下所示：
private static final RejectedExecutionHandler defaultHandler =
new AbortPolicy();
而AbortPolicy的rejectedExecution实现就是抛出异常，如下所示：
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
throw new RejectedExecutionException("Task " + r.toString() +
" rejected from " +
e.toString());
}
