大家好，我是三友。今日跟大家聊一聊无论是在作业中常用仍是在面试中常问的线程池，经过画图的方式来完全弄懂线程池的作业原理，以及在实践项目中该怎样自定义适合事务的线程池。
一、什么是线程池
线程池其实是一种池化的技能的完结，池化技能的中心思维其实便是完结资源的一个复用，避免资源的重复创立和毁掉带来的功用开支。在线程池中，线程池能够办理一堆线程，让线程履行完使命之后不会进行毁掉，而是持续去处理其它线程现已提交的使命。
运用线程池的优点
- 下降资源耗费。经过重复运用已创立的线程下降线程创立和毁掉造成的耗费。
- 提高响应速度。当使命到达时，使命能够不需求的比及线程创立就能当即履行。
- 提高线程的可办理性。线程是稀缺资源，假如无限制的创立，不只会耗费体系资源，还会下降体系 的稳定性，运用线程池能够进行一致的分配，调优和监控。
二、线程池的结构
Java中主要是经过构建ThreadPoolExecutor来创立线程池的。接下来咱们看一下线程池是怎样结构出来的
ThreadPoolExecutor的结构办法
- corePoolSize：线程池中用来作业的中心的线程数量。
- maximumPoolSize：最大线程数，线程池答应创立的最大线程数。
- keepAliveTime：超出 corePoolSize 后创立的线程存活时刻或许是一切线程最大存活时刻，取决于装备。
- unit：keepAliveTime 的时刻单位。
- workQueue：使命行列，是一个堵塞行列，当线程数已到达中心线程数，会将使命存储在堵塞行列中。
- threadFactory ：线程池内部创立线程所用的工厂。
- handler：回绝战略；当行列已满而且线程数量到达最大线程数量时，会调用该办法处理该使命。
线程池的结构其实很简单，便是传入一堆参数，然后进行简单的赋值操作。
三、线程池的运转原理
说完线程池的中心结构参数的意思，接下来就来画图解说这些参数在线程池中是怎样作业的。
线程池刚创立出来是什么姿态呢，如下图
不错，刚创立出来的线程池中只要一个结构时传入的堵塞行列而已，此刻里边并没有的任何线程，可是假如你想要在履行之前现已创立好中心线程数，能够调用prestartAllCoreThreads办法来完结，默许是没有线程的。
当有线程经过execute办法提交了一个使命，会产生什么呢？
提交使命的时分，其实会去进行使命的处理
首先会去判别当时线程池的线程数是否小于中心线程数，也便是线程池结构时传入的参数corePoolSize。
假如小于，那么就直接经过ThreadFactory创立一个线程来履行这个使命，如图
当使命履行完之后，线程不会退出，而是会去从堵塞行列中获取使命，如下图
接下来假如又提交了一个使命，也会按照上述的过程，去判别是否小于中心线程数，假如小于，仍是会创立线程来履行使命，履行完之后也会从堵塞行列中获取使命。这儿有个细节，便是提交使命的时分，就算有线程池里的线程从堵塞行列中获取不到使命，假如线程池里的线程数仍是小于中心线程数，那么仍然会持续创立线程，而不是复用已有的线程。
假如线程池里的线程数不再小于中心线程数呢？那么此刻就会测验将使命放入堵塞行列中，入队成功之后，如图
这样在堵塞的线程就能够获取到使命了。
可是，跟着使命越来越多，行列现已满了，使命放入失利了，那怎样办呢？
此刻就会判别当时线程池里的线程数是否小于最大线程数，也便是入参时的maximumPoolSize参数
假如小于最大线程数，那么也会创立非中心线程来履行提交的使命，如图
所以，从这儿能够发现，就算行列中有使命，新创立的线程仍是优先处理这个提交的使命，而不是从行列中获取已有的使命履行，从这能够看出，先提交的使命不必定先履行。
可是不幸的事产生了，线程数现已到达了最大线程数量，那么此刻会怎样办呢？
此刻就会履行回绝战略，也便是结构线程池的时分，传入的RejectedExecutionHandler目标，来处理这个使命。
RejectedExecutionHandler的完结JDK自带的默许有4种
- AbortPolicy：丢掉使命，抛出运转时反常
- CallerRunsPolicy：由提交使命的线程来履行使命
- DiscardPolicy：丢掉这个使命，可是不抛反常
- DiscardOldestPolicy：从行列中除掉最先进入行列的使命，然后再次提交使命
线程池创立的时分，假如不指定回绝战略就默许是AbortPolicy战略。当然，你也能够自己完结RejectedExecutionHandler接口，比方将使命存在数据库或许缓存中，这样就数据库或许缓存中获取到被回绝掉的使命了。
到这儿，咱们发现，线程池结构的几个参数corePoolSize、maximumPoolSize、workQueue、threadFactory、handler咱们都在上述的履行过程中讲到了，那么还差两个参数keepAliveTime和unit(unit是keepAliveTime的时刻单位)没讲到，所以keepAliveTime是怎样起到效果的呢，这个问题留到后边剖析。
说完整个履行的流程，接下来看看execute办法代码是怎样完结的。
- workerCountOf(c)<corePoolSize:这行代码便是判别是否小于中心线程数，是的话就经过addWorker办法，addWorker便是增加线程来履行使命。
- workQueue.offer(command)：这行代码就表明测验往堵塞行列中增加使命
- 增加失利之后就会再次调用addWorker办法测验增加非中心线程来履行使命
- 假如仍是增加非中心线程失利了，那么就会调用reject(command)来回绝这个使命。
最后再来另画一张图总结execute履行流程
四、线程池中线程完结复用的原理
线程池的中心功用便是完结了线程的重复运用，那么线程池是怎样完结线程的复用呢？
线程在线程池内部其实是被封装成一个Worker目标
Worker承继了AQS，也便是有必定锁的特性。
创立线程来履行使命的办法上面说到是经过addWorker办法创立的。在创立Worker目标的时分，会把线程和使命一起封装到Worker内部，然后调用runWorker办法来让线程履行使命，接下来咱们就来看一下runWorker办法。
从这张图能够看出线程履行完使命不会退出的原因，runWorker内部运用了while死循环，当第一个使命履行完之后，会不断地经过getTask办法获取使命，只要能获取到使命，就会调用run办法，持续履行使命，这便是线程能够复用的主要原因。
可是假如从getTask获取不到办法的时分，最后就会调用finally中的processWorkerExit办法，来将线程退出。
这儿有个一个细节便是，因为Worker承继了AQS，每次在履行使命之前都会调用Worker的lock办法，履行完使命之后，会调用unlock办法，这样做的目的就能够经过Woker的加锁状况就能判别出当时线程是否正在运转使命。假如想知道线程是否正在运转使命，只需求调用Woker的tryLock办法，根据是否加锁成功就能判别，加锁成功阐明当时线程没有加锁，也就没有履行使命了，在调用shutdown办法封闭线程池的时分，就用这种方式来判别线程有没有在履行使命，假如没有的话，来测验打断没有履行使命的线程。
五、线程是怎样获取使命的以及怎样完结超时的
上一节咱们说到，线程在履行完使命之后，会持续从getTask办法中获取使命，获取不到就会退出。接下来咱们就来看一看getTask办法的完结。
getTask办法，前面便是线程池的一些状况的判别，这儿有一行代码
boolean timed = allowCoreThreadTimeOut || wc > corePoolSize;
这行代码是判别，当时过来获取使命的线程是否能够超时退出。假如allowCoreThreadTimeOut设置为true或许线程池当时的线程数大于中心线程数，也便是corePoolSize，那么该获取使命的线程就能够超时退出。
那是怎样做到超时退出呢，便是这行中心代码
Runnable r = timed ?
workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS) :
workQueue.take();
会根据是否答应超时来挑选调用堵塞行列workQueue的poll办法或许take办法。假如答应超时，则会调用poll办法，传入keepAliveTime，也便是结构线程池时传入的空闲时刻，这个办法的意思便是从行列中堵塞keepAliveTime时刻来获取使命，获取不到就会回来null；假如不答应超时，就会调用take办法，这个办法会一向堵塞获取使命，直到从行列中获取到使命位置。从这儿能够看到keepAliveTime是怎样运用的了。
所以到这儿应该就知道线程池中的线程为什么能够做到空闲必守时刻就退出了吧。其实最主要的是运用了堵塞行列的poll办法的完结，这个办法能够指定超时时刻，一旦线程到达了keepAliveTime还没有获取到使命，那么就会回来null，上一小节说到，getTask办法回来null，线程就会退出。
这儿也有一个细节，便是判别当时获取使命的线程是否能够超时退出的时分，假如将allowCoreThreadTimeOut设置为true，那么一切线程走到这个timed都是true，那么一切的线程，包含中心线程都能够做到超时退出。假如你的线程池需求将中心线程超时退出，那么能够经过allowCoreThreadTimeOut办法将allowCoreThreadTimeOut变量设置为true。
整个getTask办法以及线程超时退出的机制如图所示
六、线程池的5种状况
线程池内部有5个常量来代表线程池的五种状况
- RUNNING：线程池创立时便是这个状况，能够接纳新使命，以及对已增加的使命进行处理。
- SHUTDOWN：调用shutdown办法线程池就会转换成SHUTDOWN状况，此刻线程池不再接纳新使命，但能持续处理已增加的使命到行列中使命。
- STOP：调用shutdownNow办法线程池就会转换成STOP状况，不接纳新使命，也不能持续处理已增加的使命到行列中使命，而且会测验中断正在处理的使命的线程。
- TIDYING：
SHUTDOWN 状况下，使命数为 0， 其他一切使命已停止，线程池会变为 TIDYING 状况。
线程池在 SHUTDOWN 状况，使命行列为空且履行中使命为空，线程池会变为 TIDYING 状况。
线程池在 STOP 状况，线程池中履行中使命为空时，线程池会变为 TIDYING 状况。 - TERMINATED：线程池完全停止。线程池在 TIDYING 状况履行完 terminated() 办法就会转变为 TERMINATED 状况。
线程池状况详细是存在ctl成员变量中，ctl中不只存储了线程池的状况还存储了当时线程池中线程数的巨细
private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING, 0));
最后画个图来总结一下这5种状况的流通
其实，在线程池运转过程中，绝大多数操作履行前都得判别当时线程池处于哪种状况，再来决定是否持续履行该操作。
七、线程池的封闭
线程池供给了shutdown和shutdownNow两个办法来封闭线程池。
shutdown办法
便是将线程池的状况修改为SHUTDOWN，然后测验打断空闲的线程（怎样判别空闲，上面在说Worker承继AQS的时分说过），也便是在堵塞等待使命的线程。
shutdownNow办法
便是将线程池的状况修改为STOP，然后测验打断一切的线程，从堵塞行列中移除剩下的使命，这也是为什么shutdownNow不能履行剩下使命的原因。
所以也能够看出shutdown办法和shutdownNow办法的主要区别便是，shutdown之后还能处理在行列中的使命，shutdownNow直接就将使命从行列中移除，线程池里的线程就不再处理了。
八、线程池的监控
在项目中运用线程池的时分，一般需求对线程池进行监控，方便出问题的时分进行检查。线程池自身供给了一些办法来获取线程池的运转状况。
- getCompletedTaskCount：现已履行完结的使命数量
- getLargestPoolSize：线程池里曾经创立过的最大的线程数量。这个主要是用来判别线程是否满过。
- getActiveCount：获取正在履行使命的线程数据
- getPoolSize：获取当时线程池中线程数量的巨细\
除了线程池供给的上述现已完结的办法，一起线程池也预留了很对扩展办法。比方在runWorker办法里边，在履行使命之前会回调beforeExecute办法，履行使命之后会回调afterExecute办法，而这些办法默许都是空完结，你能够自己承继ThreadPoolExecutor来扩展重写这些办法，来完结自己想要的功用。
九、Executors构建线程池以及问题剖析
JDK内部供给了Executors这个东西类，来快速的创立线程池。
1）固定线程数量的线程池：中心线程数与最大线程数持平
2）单个线程数量的线程池
3）挨近无限大线程数量的线程池
4）带守时调度功用的线程池
虽然JDK供给了快速创立线程池的办法，可是其实不引荐运用Executors来创立线程池，因为从上面结构线程池能够看出，newFixedThreadPool线程池，因为运用了LinkedBlockingQueue，行列的容量默许是无限大，实践运用中出现使命过多时会导致内存溢出；newCachedThreadPool线程池因为中心线程数无限大，当使命过多的时分，会导致创立很多的线程，或许机器负载过高，或许会导致服务宕机。
十、线程池的运用场景
在java程序中，其实常常需求用到多线程来处理一些事务，可是不建议单纯运用承继Thread或许完结Runnable接口的方式来创立线程，那样就会导致频繁创立及毁掉线程，一起创立过多的线程也或许引发资源耗尽的危险。所以在这种情况下，运用线程池是一种更合理的挑选，方便办理使命，完结了线程的重复运用。所以线程池一般适合那种需求异步或许多线程处理使命的场景。
十一、实践项目中怎样合理的自定义线程池
经过上面剖析说到，经过Executors这个东西类来创立的线程池其实都无法满足实践的运用场景，那么在实践的项目中，到底该怎样结构线程池呢，该怎样合理的设置参数？
1）线程数
线程数的设置主要取决于事务是IO密集型仍是CPU密集型。
CPU密集型指的是使命主要运用来进行很多的核算，没有什么导致线程堵塞。一般这种场景的线程数设置为CPU中心数+1。
IO密集型：当履行使命需求很多的io，比方磁盘io，网络io，或许会存在很多的堵塞，所以在IO密集型使命中运用多线程能够大大地加速使命的处理。一般线程数设置为 2*CPU中心数
java中用来获取CPU中心数的办法是：Runtime.getRuntime().availableProcessors();
2）线程工厂
一般建议自定义线程工厂，构建线程的时分设置线程的名称，这样就在查日志的时分就方便知道是哪个线程履行的代码。
3）有界行列
一般需求设置有界行列的巨细，比方LinkedBlockingQueue在结构的时分就能够传入参数，来限制行列中使命数据的巨细，这样就不会因为无限往行列中扔使命导致体系的oom。
以上便是本篇文章的全部内容，假如你有什么不懂或许想要沟通的地方，能够重视我的个人的微信大众号三友的java日记或许增加我的微信ZZYNKXJH联络我，咱们下篇文章再会。
假如觉得这篇文章对你有所帮助，还请帮忙点赞、在看、转发一下，码字不易，非常感谢！
往期文章引荐 【springcloud系列文章】
【SpringCloud原理】nacos是怎样进行服务注册的
【SpringCloud原理】nacos是怎样整合springcloud — 注册中心篇
【SpringCloud原理】OpenFeign之FeignClient动态署理生成原理
【SpringCloud原理】Ribbon中心组件以及运转原理源码剖析
【SpringCloud原理】OpenFeign原来是这么基于Ribbon来完结负载均衡的
