线程池参数详解及其工作原理

线程池的作用及优势

线程池做的工作主要是控制运行的线程的数量,处理过程中将任务加入队列,然后在线程创建后启动这些任务,如果提交的任务超过了线程能执行的最大数量,超出的数量的任务会被提交到一个阻塞队列排队等候,等其他线程执行完毕,再从队列中取出任务来执行.

主要特点为:线程复用:控制最大并发数:管理线程.

第一:降低资源消耗.通过重复利用自己创建的线程降低线程创建和销毁造成的消耗.
第二: 提高响应速度.当任务到达时,任务可以不需要等到线程创建就能立即执行.
第三: 提高线程的可管理性.线程是稀缺资源,如果无限的创建,不仅会消耗资源,还会降低系统的稳定性,使用线程池可以进行统一分配,调优和监控.

线程池的种类

JAVA8中JDK有5种定义好的线程池，分别是：

FixedThreadPool: 创建一个定长线程池,可控制线程的最大并发数，超出的线程会在队列中等待，newFixedThreadPool创建的线程池corePoolSize和MaxmumPoolSize是相等的,它使用的任务队列是LinkedBlockingQueue。

SingleThreadPool:创建一个单线程化的线程池，它只会用唯一的工作线程来执行任务，保证所有任务都按照指定顺序执行。newSingleThreadExecutor将corePoolSize和MaxmumPoolSize都设置为1，它使用的任务队列是LinkedBlockingQueue。

CacheThreadPool:创建一个可缓存线程池,如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则创建新线程。newCachedThreadPool将corePoolSize设置为0，MaxmumPoolSize设置为Integer.MAX_VALUE，它使用的是SynchronousQUeue，也就是说来了任务就创建线程运行,如果线程空闲超过60秒,就销毁线程。

ScheduledThreadPool:创建一个可以按时间周期执行任务的线程池，使用的任务队列是DelayedWorkQueue。

WorkStealingPool:java8新增,使用目前机器上可以的处理器作为他的并行级别。

以上五种线程池都可以使用Executors来创建：

ps：JDK已经定义好的线程池存在一些问题，例如：

这里指定的任务队列并没有指定其队列容量，直接new会创建一个容量默认的阻塞队列：

队列长度是Integer.MAX_VALUE，这个长度是2^31

由于队列的容量几乎为无界，所以可能会致使任务大量堆积，从而OOM。在使用线程池时，最好使用ThreadPoolExecutor的构造函数来创建。

创建线程池的参数

 public ThreadPoolExecutor( //线程池中的常驻核心线程数int corePoolSize,//线程池能够容纳同时执行的最大线程数,此值大于等于1int maximumPoolSize,//多余的空闲线程存活时间,当空间时间达到keepAliveTime值时,多余的线程会被销毁直到只剩下corePoolSize个线程为止long keepAliveTime,//keepAliveTime的单位TimeUnit unit,// 任务队列,被提交但尚未被执行的任务.BlockingQueue<Runnable> workQueue,// 表示生成线程池中工作线程的线程工厂,用户创建新线程,一般用默认即可ThreadFactory threadFactory,// 拒绝策略,表示当线程队列满了并且工作线程大于等于线程池的最大显示 数(maxnumPoolSize)时如何来拒绝.RejectedExecutionHandler handler) {...

总共有7个参数，其中corePoolSize的含义是：1.在创建了线程池后,当有请求任务来之后,就会安排池中的线程去执行请求任务,可以理解为最少存在的线程数。
2.当线程池中的线程数目达到corePoolSize后,就会把到达的任务放入到缓存队列当中。而keepAliveTime是指多余的空闲线程存活时间,当空间时间达到keepAliveTime值时,多余的线程会被销毁直到只剩下corePoolSize个线程为止。

线程池的拒绝策略

线程池拒绝策略也就是上面参数中的RejectedExecutionHandler，线程池有4种拒绝策略，它们都是RejectedExecutionHandler接口的实现类。

AbortPolicy：直接抛出异常。

CallerRunsPolicy：将任务返回给调用者所在线程来运行任务。

DiscardOldestPolicy：丢弃队列里等待最久的一个任务，并执行当前任务。

DiscardPolicy：不处理，丢弃掉。

通过实现RejectedExecutionHandler接口可以自定义拒绝策略，但是拒绝策略是一种处理较为极端的情况的方式，正常情况下尽量通过合理的设计线程池来防止溢出。

线程池的工作流程

画了个简单的示意图：