前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Java线程池---ShutDown以及ShutDownNow解析

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

作者头像
None_Ling
发布2018-10-24 15:04:21
8040
发布2018-10-24 15:04:21
举报
文章被收录于专栏:Android相关

ShutDown函数的注释:

代码语言:javascript
复制
/**
 * 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方法。

该函数的代码为:

代码语言:javascript
复制
public void shutdown() {
    final ReentrantLock mainLock = this.mainLock;
    mainLock.lock();
    try {
        checkShutdownAccess();
        advanceRunState(SHUTDOWN);
        interruptIdleWorkers();
        onShutdown(); // hook for ScheduledThreadPoolExecutor
    } finally {
        mainLock.unlock();
    }
    tryTerminate();
}
  1. 获取线程池的锁,然后调用checkShutdownAccess方法检查每一个线程池的线程是否有可以ShutDown的权限。
  2. 调用advanceRunState函数通过自旋的CAS操作来将ctl中的状态变为SHUTDOWN
  3. 调用interruptIdleWorkers方法,将所有Idle状态的线程都调用interrupt方法,中断线程。而判断idle状态使用Worker中的ReentrantLock来调用tryLock尝试加锁,看Worker线程是否已经获取了锁,如果Worker的锁已经被加了的话,那么tryLock返回的就是false。
  4. 通过onShutDown()方法告知子类,线程池要处于ShutDown状态了。
  5. 解锁完后,调用tryTermiante的方法尝试终止线程池。

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

代码语言:javascript
复制
 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;
}

这两个方法的区别有:

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

而在tryTermiante方法中:

代码语言:javascript
复制
 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
    }
}
  1. 判断当前线程池是否正在运行,或者当前线程池的状态比TIDYING(整理中)要大(也就是处于TIDYING或者TERMINATED状态),或者当前线程状态处于SHUTDOWN并且任务队列不为空的话,那么就直接return
  2. 如果当前的WorkerCount不为0,那么就会调用interruptedIdleWorkers(true),并且返回
  3. 通过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 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档