Java之ThreadPoolExcutor和四种常见的线程池（1）

一、ThreadPoolExcutors的作用

java提供了ThreadPoolExcutors来创建一个线程池，我们为什么要用线程池呢?

1.降低资源的消耗：

通过重复利用已经创建好的线程降低线程的创建和销毁带来的损耗

2.提高响应速度：

因为线程池中的线程处于等待分配任务的状态，当任务来时无需创建新的线程就能执行

3.提高线程的可管理性

二、ThreadPoolExecutor构造函数参数详细介绍

public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit unit,
                          BlockingQueue<Runnable> workQueue,
                          ThreadFactory threadFactory,
                          RejectedExecutionHandler handler)      

1.int corePoolSize（核心线程数）

线程池新建线程的时候，如果当前线程总数小于corePoolSize，则新建的是核心线程，如果超过corePoolSize，则新建的是非核心线程；核心线程默认情况下会一直存活在线程池中，即使这个核心线程啥也不干(闲置状态)；如果设置了 allowCoreThreadTimeOut 为 true，那么核心线程如果不干活(闲置状态)的话，超过一定时间(时长下面参数决定)，就会被销毁掉。

2.int maximumPoolSize（线程池能容纳的最大线程数量）

线程总数 = 核心线程数 + 非核心线程数。

3.long keepAliveTime（非核心线程空闲存活时长）

非核心线程空闲时长超过该时长将会被回收，主要应用在缓存线程池中，当设置了 allowCoreThreadTimeOut 为 true 时，对核心线程同样起作用。

4.TimeUnit unit

空闲线程的存活时间（keepAliveTime 的单位）它是一个枚举类型，常用的如：TimeUnit.SECONDS（秒）、TimeUnit.MILLISECONDS（毫秒）。

5.BlockingQueue workQueue（任务队列）

当所有的核心线程都在干活时，新添加的任务会被添加到这个队列中等待处理，如果队列满了，则新建非核心线程执行任务

常用的workQueue类型：

（1）SynchornousQueue：

这队列接收到任务时会直接交给线程处理，而不保留它，如果所有的线程都在工作，那就创建一   个新的线程来处理这个任务，为了保证不出现线程数达到maxnumPoolSize而不能新建线程的错误，所以使用这个类型 的队列时，maxnumPoolSize一般指定成Integer.MAX_VALUE，即无限大，然后核心线程数corePoolSize一般是0.

（2）LinkedBlockingQueue：

这个队列接收到任务的时候，如果当前线程数小于核心线程数，则新建线程(核心线程)处理任务；如果当前线程数等于核心线程数，则进入队列等待。由于这个队列没有最大值限制，即所有超过核心线程数的任务都将被添加到队列中，这也就导致了 maximumPoolSize 的设定失效，因为总线程数永远不会超过 corePoolSize。

（3）ArrayBlockingQueue

可以限定队列的长度，接收到任务的时候，如果没有达到 corePoolSize 的值，则新建线程(核心线程)执行任务，如果达到了，则入队等候，如果队列已满，则新建线程(非核心线程)执行任务，又如果总线程数到了 maximumPoolSize，并且队列也满了，则发生错误。

（4）DelayQueue：

队列内元素必须实现 Delayed 接口，这就意味着你传进去的任务必须先实现 Delayed 接口。这个队列接收到任务时，首先先入队，只有达到了指定的延时时间，才会执行任务。

6.ThreadFactory threadFactory（线程工厂）：

用来创建线程池中的线程，通常用默认的即可

7.RejectedExecutionHandler handler（拒绝策略）：

在线程池已经关闭的情况下和任务太多导致最大线程数和任务队列已经饱和，无法再接收新的任务，在上面两种情况下，只要满足其中一种时，在使用 execute() 来提交新的任务时将会拒绝，线程池提供了以下 4 种策略：

AbortPolicy：

默认策略，在拒绝任务时，会抛出RejectedExecutionException。

CallerRunsPolicy：

只要线程池未关闭，该策略直接在调用者线程中，运行当前的被丢弃的任务。

DiscardOldestPolicy：

该策略将丢弃最老的一个请求，也就是即将被执行的任务，并尝试再次提交当前任务。

DiscardPolicy：

该策略默默的丢弃无法处理的任务，不予任何处理。

线程池遵循的原则：

其会优先创建核心线程，执行任务，当核心线程增加CorePoolSize后，我们会把任务添加到work Queue中，当work Queue里面的任务也塞满了，线程池就会创建非核心线程执行去执行任务，当线程达到maximumPoolSize时候和work queue也达最大值时候我们会执行对应的拒绝策略