线程池的优点

1、线程是稀缺资源，使用线程池可以减少创建和销毁线程的次数，每个工作线程都可以重复使用。

2、可以根据系统的承受能力，调整线程池中工作线程的数量，防止因为消耗过多内存导致服务器崩溃。

线程池的创建

1 public ThreadPoolExecutor(int corePoolSize,

2 int maximumPoolSize,

3 long keepAliveTime,

4 TimeUnit unit,

5 BlockingQueue workQueue,

6 RejectedExecutionHandler handler)

corePoolSize：线程池核心线程数量

maximumPoolSize:线程池最大线程数量

keepAliverTime：当活跃线程数大于核心线程数时，空闲的多余线程最大存活时间

unit：存活时间的单位

workQueue：存放任务的队列

handler：超出线程范围和队列容量的任务的处理程序

线程池的实现原理

提交一个任务到线程池中，线程池的处理流程如下：

1、判断线程池里的核心线程是否都在执行任务，如果不是(核心线程空闲或者还有核心线程没有被创建)则创建一个新的工作线程来执行任务。如果核心线程都在执行任务，则进入下个流程。

2、线程池判断工作队列是否已满，如果工作队列没有满，则将新提交的任务存储在这个工作队列里。如果工作队列满了，则进入下个流程。

3、判断线程池里的线程是否都处于工作状态，如果没有，则创建一个新的工作线程来执行任务。如果已经满了，则交给饱和策略来处理这个任务。

线程池的源码解读

1、ThreadPoolExecutor的execute()方法

1 public void execute(Runnable command) {

2 if (command == null)

3 throw new NullPointerException();

//如果线程数大于等于基本线程数或者线程创建失败，将任务加入队列

4 if (poolSize >= corePoolSize || !addIfUnderCorePoolSize(command)) {

//线程池处于运行状态并且加入队列成功

5 if (runState == RUNNING && workQueue.offer(command)) {

6 if (runState != RUNNING || poolSize == 0)

7 ensureQueuedTaskHandled(command);

8 }

//线程池不处于运行状态或者加入队列失败，则创建线程(创建的是非核心线程)

9 else if (!addIfUnderMaximumPoolSize(command))

//创建线程失败，则采取阻塞处理的方式

10 reject(command); // is shutdown or saturated