1.导语

最近在工作中，有遇到下面这样一段代码，某个同事一看到代码中的shutdown()，马上就断定这代码执行不了，我问为什么这么说，他说线程池都关了，这任务怎么执行？不能说没有问题，但事实真如他所说吗，我们来探一探shutdown()的虚实。

简单代码

2.shutdown 源码

shutdown 源码

从shutdown 源码的注释我们可以看到，它会初始化一个顺序的已提交的任务的关闭操作，并且不再接受新的任务；如果线程池已经被showdown了，那么该方法的调用将没有任何的效果了。

下面我来对showdown内部调用的方法做个解析。

checkShutdownAccess

checkShutdownAccess

这个方法其实没什么说的，比较简单，就是对workers的线程做一个安全权限检查。

advanceRunState

advanceRunState

该方法通过cas操作设置runState。如果当前的线程池的状态值大于给定的值，，也即是runStateAtLeast(c, targetState) 返回true ，那么就不做任何操作了，直接break；如果返回false，那么就看ctl.compareAndSet(c, ctlOf(targetState, workerCountOf(c))) 设置是否成功，否则一直重复这个过程。

interruptIdleWorkers

interruptIdleWorkers

里面有一个interruptIdleWorkers 方法，默认传了false。传false的意思是把，在获取锁的情况下，把workers的线程都执行interrupt()操作。

interruptIdleWorkers

interruptIdleWorkers

注释说明，中断可能正在等待任务的线程(表示没有被锁定)以便他们可以检查终止或配置更改。忽略SecurityExceptions(在这种情况下，某些线程可能会保留不间断)。

如果线程没有被interrupt 并且tryLock到锁了，那么就可以判定这是一个IdleWorkers，将会执行interrupt() 方法。如果worker线程在执行任务，runWorker方法中中执行的Worker是占有锁的，这里也就无法获取到锁，即tryLock不到，就是非IdleWorkers。

tryTerminate

tryTerminate

先看注释，如果线程池状态是shutdown并且线程池和队列是空的，或者线程池是stop状态并且线程池是空的，把他改为terminate状态；如果线程池可以被terminate，但是workerCount 不为0，终止一个dle worker来确保 shutdown 信号传递下去。该方法一定要跟在任何可能会使terminate的操作之后----减少worker count 或在showdow中从队列中移除任务。

if (isRunning(c) ||                runStateAtLeast(c, TIDYING) ||                (runStateOf(c) == SHUTDOWN && ! workQueue.isEmpty()))                return;//如果线程池的状态是isRunning，或者状态值>=TIDYING,或者SHUTDOWN并且workQueue不为//空，直接返回

if (workerCountOf(c) != 0) { // Eligible to terminate                interruptIdleWorkers(ONLY_ONE);                return; }//如果workerCountOf 不为0，表示可以被terminate，interruptIdleWorkers(true) 线程后将 //shutdown 信号传递下去。

if (ctl.compareAndSet(c, ctlOf(TIDYING, 0))) {  try {    terminated();  } finally {    ctl.set(ctlOf(TERMINATED, 0));    termination.signalAll();  }  return;}//这里通过cas 将状态设置为TIDYING，如果成功则调用 terminated()方法，执行成功后，最后 将状态//设置为TERMINATED，并唤醒awaitTermination中等待的线程。

实例

ThreadPoolExecutor poolExecutor = new ThreadPoolExecutor(5, 10, 30, TimeUnit.SECONDS, new ArrayBlockingQueue<>(5));        for (int i = 0; i < 5; i++) {            poolExecutor.submit(new MyTask());        }        poolExecutor.shutdown();try {                //5秒后关闭                poolExecutor.awaitTermination(5, TimeUnit.SECONDS);            } catch (InterruptedException e) {                System.out.println(e.getMessage());            }*/class MyTask implements Runnable {    @Override    public void run() {        try {            System.out.println(Thread.currentThread().getName());            Thread.sleep(3000);        }catch (Exception e) {            System.out.println(e.getMessage());        }    }}

小结

通过以上的一些分析，当然不够全面，还有一些方法没有说明，以及一个demo，我们可以看到线程池关闭都能正确输出结果。线程池关闭的关键就在于一个worker退出后会调用tryTerminate()，将这种信号传递下去，其他的线程才能被依次处理，最终尘归尘，变为 Terminate。

好了，喜欢的朋友点赞+关注+转发，与小编共同成长[奋斗][奋斗][奋斗]