线程池系列(3)ThreadPoolExecutor空闲线程的销毁原理

源码:版本JDK8

1. 起因

JDK线程池提供了一些核心参数,用于空闲maximum线程的销毁和空闲core线程的销毁。

参数信息.png

文章来源:线程池系列(1)—ThreadPoolExecutor线程池参数以及使用

2. 分析

灯下黑?原来线程池是最典型生产消费者模式文章中,我们知道,线程池的工作线程本质是死循环去处理任务,而销毁工作线程的原理,即跳出循环。

工作线程会不断的去阻塞队列中拉取任务,此处有两个方法:

  1. poll:拉取任务(可能有等待时间),拉取不到(或超过等待时间)返回null;
  2. task:阻塞式的拉取任务,只要拉取不到,便一直阻塞;

  1. 具体走什么逻辑拉取任务:取决于timed参数。
  2. timed取决于:如果配置了allowCoreThreadTimeout参数,或者当前线程数大于核心线程数,则返回true,于是则使用poll方法获取参数。
获取task的方法.png
  1. 当拉取不到任务,将timeOut=true;
  2. 在下一次自旋时,会使得当前工作线程数-1,并且返回null;
工作线程自旋拉取任务.png
  1. 不满足自旋条件,将completedAbruptly设置为true;
  2. 调用processWorkerExit方法去真正销毁自己,但此时,不一定真正被销毁;
    private void processWorkerExit(Worker w, boolean completedAbruptly) {
        if (completedAbruptly) // If abrupt, then workerCount wasn't adjusted
            decrementWorkerCount();

        final ReentrantLock mainLock = this.mainLock;
        mainLock.lock();
        try {
            completedTaskCount += w.completedTasks;
            workers.remove(w);
        } finally {
            mainLock.unlock();
        }

        tryTerminate();

        int c = ctl.get();
        if (runStateLessThan(c, STOP)) {
            if (!completedAbruptly) {
                //若允许销毁空闲的核心线程,则允许剩余的线程数为0
                int min = allowCoreThreadTimeOut ? 0 : corePoolSize;
                //在销毁过程中,发现阻塞队列有任务,则允许剩余的线程数为1
                if (min == 0 && ! workQueue.isEmpty())
                    min = 1;
                //销毁过程中,工作线程数必须大于等于最小线程数,才允许销毁自己。
                if (workerCountOf(c) >= min)
                    //分支1:结束流程,工作线程被销毁
                    return; // replacement not needed
            }
            //分支2:继续while循环去处理任务(该工作线程未被销毁)
            addWorker(null, false);
        }
    }
  1. 若在销毁的流程中,发现阻塞队列中有任务需要被执行,但是该线程为最后一个线程时,会执行到分支2,再去开启while循环。

3. 总结

线程池销毁核心线程,依赖的API是queue的poll。当在keepAliveTime时间内拉取不到任务,则会中断工作线程的while循环,开始销毁任务。但是最终是否要销毁线程,还取决于阻塞队列中是否为空。

想想一个场景:线程池:只有一个核心线程。

  1. 当任务进来时,发现当前线程数=核心线程数,于是将任务放入到queue中;
  2. 但是任务放入queue的前一刻,工作线程通过getTask()在keepAliveTime时间内未拉取到任务,触发销毁工作线程的方法;
  3. processWorkerExit中没有进一步校验,直接去销毁方法,会导致任务进入阻塞队列,但是没有工作线程去执行改任务,产生bug;

系列文章

线程池系列(1)ThreadPoolExecutor线程池参数以及使用
线程池系列(2) ThreadPoolExecutor的实现原理(源码分析)

灯下黑?原来线程池是最典型生产消费者模式

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 220,137评论 6 511
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 93,824评论 3 396
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 166,465评论 0 357
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 59,131评论 1 295
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 68,140评论 6 397
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,895评论 1 308
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,535评论 3 420
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,435评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,952评论 1 319
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 38,081评论 3 340
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 40,210评论 1 352
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,896评论 5 347
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,552评论 3 331
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 32,089评论 0 23
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,198评论 1 272
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,531评论 3 375
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 45,209评论 2 357

推荐阅读更多精彩内容