Java线程池---ShutDown以及ShutDownNow解析

None_Ling

发布于 2018-10-24 15:04:21

8040

发布于 2018-10-24 15:04:21

文章被收录于专栏：Android相关

ShutDown函数的注释:

/**
 * Initiates an orderly shutdown in which previously submitted
 * tasks are executed, but no new tasks will be accepted.
 * Invocation has no additional effect if already shut down.
 *
 * <p>This method does not wait for previously submitted tasks to
 * complete execution.  Use {@link #awaitTermination awaitTermination}
 * to do that.
 *
 * @throws SecurityException {@inheritDoc}
 */

初始化一个有序的关闭，之前提交的任务都会被执行，但是新提交的任务则不会被允许放入任务队列中。如果之前被调用过了的话，那么再次调用也没什么用。这个方法不会等待之前提交的任务完成执行，如果希望的话，则需要调用awaitTermiante方法。

该函数的代码为：

public void shutdown() {
    final ReentrantLock mainLock = this.mainLock;
    mainLock.lock();
    try {
        checkShutdownAccess();
        advanceRunState(SHUTDOWN);
        interruptIdleWorkers();
        onShutdown(); // hook for ScheduledThreadPoolExecutor
    } finally {
        mainLock.unlock();
    }
    tryTerminate();
}

获取线程池的锁，然后调用checkShutdownAccess方法检查每一个线程池的线程是否有可以ShutDown的权限。
调用advanceRunState函数通过自旋的CAS操作来将ctl中的状态变为SHUTDOWN
调用interruptIdleWorkers方法，将所有Idle状态的线程都调用interrupt方法，中断线程。而判断idle状态使用Worker中的ReentrantLock来调用tryLock尝试加锁，看Worker线程是否已经获取了锁，如果Worker的锁已经被加了的话，那么tryLock返回的就是false。
通过onShutDown()方法告知子类，线程池要处于ShutDown状态了。
解锁完后，调用tryTermiante的方法尝试终止线程池。

ShutDownNow方法和ShutDown方法差不多。具体看下面的代码

 public List<Runnable> shutdownNow() {
    List<Runnable> tasks;
    final ReentrantLock mainLock = this.mainLock;
    mainLock.lock();
    try {
        checkShutdownAccess();
        advanceRunState(STOP);
        interruptWorkers();
        tasks = drainQueue();
    } finally {
        mainLock.unlock();
    }
    tryTerminate();
    return tasks;
}

这两个方法的区别有：

shutDownNow方法会返回未完成的任务队列中的任务列表
advanceRunState方法中传入的是STOP，而不是SHUTDOWN。

而在tryTermiante方法中：

 final void tryTerminate() {
    for (;;) {
        int c = ctl.get();
        if (isRunning(c) ||
            runStateAtLeast(c, TIDYING) ||
            (runStateOf(c) == SHUTDOWN && ! workQueue.isEmpty()))
            return;
        if (workerCountOf(c) != 0) { // Eligible to terminate
            interruptIdleWorkers(ONLY_ONE);
            return;
        }

        final ReentrantLock mainLock = this.mainLock;
        mainLock.lock();
        try {
            if (ctl.compareAndSet(c, ctlOf(TIDYING, 0))) {
                try {
                    terminated();
                } finally {
                    ctl.set(ctlOf(TERMINATED, 0));
                    termination.signalAll();
                }
                return;
            }
        } finally {
            mainLock.unlock();
        }
        // else retry on failed CAS
    }
}

判断当前线程池是否正在运行，或者当前线程池的状态比TIDYING（整理中）要大（也就是处于TIDYING或者TERMINATED状态），或者当前线程状态处于SHUTDOWN并且任务队列不为空的话，那么就直接return
如果当前的WorkerCount不为0，那么就会调用interruptedIdleWorkers(true)，并且返回
通过CAS操作将ctl设置成TIDYING，如果设置成功之后就会调用terminated方法，告知子类，要终止了，终止完之后，就会将ctl的状态设置成TERMINATED，以及workerCount为0。

PS：在tryTerminate函数中，会有判断如果是SHUTDOWN状态的话，那么就需要判断任务队列是否为空，如果为空的话，那么就会接着往下走，如果任务队列不为空的话，那么说明还有任务没有执行完，直接返回了。在最后一个Worker运行结束后，调用的processWorkerExit函数中还会调用tryTerminate，所以到那时候，才是真正的结束。而在tryTeminate后的一句if(workerCountOf(c)!=0)成立的话，也就是说明任务队列空了，但是Worker还有多的，那么就将最多一个处于IDLE状态的Worker中断。这一段没有太明白具体要干什么。不理解。

至此，整个线程池就完全退出了。

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2016.07.02 ，如有侵权请联系 cloudcommunity@tencent.com 删除

java