问答文章1 问答文章501 问答文章1001 问答文章1501 问答文章2001 问答文章2501 问答文章3001 问答文章3501 问答文章4001 问答文章4501 问答文章5001 问答文章5501 问答文章6001 问答文章6501 问答文章7001 问答文章7501 问答文章8001 问答文章8501 问答文章9001 问答文章9501

面试官:线程池多余的线程是如何回收的?

发布网友 发布时间:2024-09-25 16:52

我来回答

1个回答

热心网友 时间:2024-10-12 21:42

最近阅读了JDK线程池ThreadPoolExecutor的源码,对线程池执行任务的流程有了大体了解,实际上这个流程也十分通俗易懂,就不再赘述了,别人写的比我好多了。

不过,我倒是对线程池是如何回收工作线程比较感兴趣,所以简单分析了一下,加深对线程池的理解吧。

下面以JDK1.8为例进行分析

1. runWorker(Worker w)

工作线程启动后,就进入runWorker(Worker w)方法。

里面是一个while循环,循环判断任务是否为空,若不为空,执行任务;若取不到任务,或发生异常,退出循环,执行processWorkerExit(w, completedAbruptly); 在这个方法里把工作线程移除掉。

取任务的来源有两个,一个是firstTask,这个是工作线程第一次跑的时候执行的任务,最多只能执行一次,后面得从getTask()方法里取任务。看来,getTask()是关键,在不考虑异常的场景下,返回null,就表示退出循环,结束线程。下一步,就得看看,什么情况下getTask()会返回null。

(篇幅有限,分段截取,省略中间执行任务的步骤)

2、getTask() 返回null

一共有两种情况会返回null,见红框处 。

第一种情况,线程池的状态已经是STOP,TIDYING, TERMINATED,或者是SHUTDOWN且工作队列为空;

第二种情况,工作线程数已经大于最大线程数或当前工作线程已超时,且,还有其他工作线程或任务队列为空。这点比较难理解,总之先记住,后面会用。

下面以条件1和条件2分别指代这两种情况的判断条件。

3、分场景分析线程池回收工作线程3.1 未调用shutdown() ,RUNNING状态下全部任务执行完成的场景

这种场景,会将工作线程的数量减少到核心线程数大小(如果本来就没有超过,则不需要回收)。

比如一个线程池,核心线程数为4,最大线程数为8。一开始是4个工作线程,当任务把任务队列塞满,就得将工作线程增加到8. 当后面任务执行到差不多了,线程取不到任务了,就会回收到4个工作线程的状态(取决于allowCoreThreadTimeOut的值,这里讨论默认值false的情况,即核心线程不会超时。如果为true,工作线程可以全部销毁)。

可以先排除上面提到的条件1,线程池的状态已经是STOP,TIDYING, TERMINATED,或者是SHUTDOWN且工作队列为空。因为线程池一直是RUNNING,这条判断永远是false。在这个场景中,可以当条件1不存在。

下面分析取不出任务时线程是怎么运行的。

step1. 从任务队列取任务有两种方式,超时等待还是可以一直阻塞下去。决定因素是timed变量。该变量在前面赋值,如果当前线程数大于核心线程数,变量timed为true, 否则为false(上面说了,这里只讨论allowCoreThreadTimeOut为false的情况)。很明显,现在讨论的是timed为true的情况。keepAliveTime一般不设置,默认值为0,所以基本上可以认为是不阻塞,马上返回取任务的结果。

在线程超时等待唤醒之后,发现取不出任务,timeOut变为true,进入下一次循环。

step2. 来到条件1的判断,线程池一直RUNNING, 不进入代码块。

step3. 来到条件2的判断,这时任务队列为空,条件成立,CAS减少线程数,若成功,返回null,否则,重复step1。

这里要注意,有可能多条线程同时通过条件2的判断,那会不会减少后线程的数量反而比预想的核心线程数少呢?

比如当前线程数已经只有5条了,此时有两条线程同时唤醒,通过条件2的判断,同时减少数量,那剩下的线程数反而只有3条,和预期不一致。

实际上是不会的。为了防止这种情况,compareAndDecrementWorkerCount(c) 用的是CAS方法,如果CAS失败就continue,进入下一轮循环,重新判断。

像上述例子,其中一条线程会CAS失败,然后重新进入循环,发现工作线程数已经只有4了,timed为false, 这条线程就不会被销毁,可以一直阻塞了(workQueue.take())。

这一点我思考了很久才得出答案,一直在想没有加锁的情况下是怎么保证一定能不多不少回收到核心线程数的呢。原来是CAS的奥妙。

从这里也可以看出,虽然有核心线程数,但线程并没有区分是核心还是非核心,并不是先创建的就是核心,超过核心线程数后创建的就是非核心,最终保留哪些线程,完全随机。

3.2 调用shutdown() ,全部任务执行完成的场景

这种场景,无论是核心线程还是非核心线程,所有工作线程都会被销毁。

在调用shutdown()之后,会向所有的空闲工作线程发送中断信号。

最终传入false,调用下面这个方法。

可以看出,在发出中断信号前,会判断是否已经中断,以及要获得工作线程的独占锁。

发出中断信号的时候,工作线程要么在getTask()里准备获取任务,要么在执行任务,那就得等它执行完当前任务才会发出,因为工作线程在执行任务的时候,也会工作线程加锁。工作线程执行完任务,又跑到getTask()里面去了。

所以我们只要看getTask()里面怎么应对中断异常的就可以了。

工作线程在getTask()里,有两种可能。

3.2.1 任务已全部完成,线程在阻塞等待。

很简单,中断信号将其唤醒,从而进入下一轮循环。到达条件1处,符合条件,减少工作线程数量,并返回null,由外层结束这条线程。

这里的decrementWorkerCount()是自旋式的,一定会减1。

3.2.2 任务还没有完全执行完

调用shutdown()之后,未执行完的任务要执行完毕,池子才能结束。所以此时有可能线程还在工作。

这里又要分两个阶段讨论

阶段1 任务较多,工作线程都能获得任务

这里还不涉及到线程退出,可以跳过不看,只是分析一下收到中断信号后线程的表现。

假设有线程A,正通过getTask()里获取任务。此时A被中断,在获取任务时,无论是poll()还是take(),都会抛出中断异常。异常被捕获,重新进入下一轮循环,只要队列不为空,就可以继续取任务。

线程A被中断,再次取任务,调用workQueue.poll() or workQueue.take(),不会抛出异常吗?还可以正常取出任务吗?

这就要看workQueue的实现了。workQueue是BlockingQueue类型,以常见的LinkedBlockingQueue和ArrayBlockingQueue为例,加锁时都是调用lockInterruptibly(),是响应中断的。该方法又调用了AQS的acquireInterruptibly(int arg)。

acquireInterruptibly(int arg),无论是在入口处判断中断异常,还是在parkAndCheckInterrupt()方法阻塞,被中断唤醒并判断中断异常时,均使用了Thread.interrupted()。这个方法会返回线程的中断状态,并把中断状态重置!也就是说,线程不再是中断状态了,这样在再次取任务时,就不会报错了。

因此,这对于正在准备取任务的线程,只是相当于浪费了一次循环,这可能是线程中断带来的副作用吧,当然,对整体的运行不影响。

分析到这里,我不禁感叹,这里BlockingQueue刚好是会重置中断状态,这到底是怎么想出来的绝妙设计啊?Doug Lea大神Orz.

阶段2 任务刚好要执行完了

这时任务已经快取完了,比如有4条工作线程,只剩下2个任务,那就可能出现2条线程获得任务,2条线程阻塞。

因为在获取任务前的判断,没有加锁,那么会不会出现,所有线程都通过了前面的校验,来到workQueue获取任务的地方,刚好任务队列已经空了,线程全部阻塞了呢?因为shutdown() 已经执行完毕,无法再向线程发出中断信号,从而线程一直在阻塞,无法被回收。

这种是不会发生的。

假设有A,B,C,D四条工作线程,同时通过了条件1和条件2的判断,来到取任务的地方。那么,工作队列至少还有一个任务,至少会有一条线程能取到任务。

假设A,B获得了任务,C,D阻塞。

A, B接下来的步骤是:

step1.任务执行完成后,再次getTask(),此时符合条件1,返回null,线程准备被回收。

step2.processWorkerExit(Worker w, boolean completedAbruptly) 将线程回收。

回收就只是把线程干掉这么简单吗?来看看processWorkerExit(Worker w, boolean completedAbruptly) 的方法。

可以看到,在里面除了workers.remove(w) 移除线,还调用了tryTerminate()。

第一个判断条件没有一个子条件符合,跳过。第二个条件,工作线程还存在,那么随机中断一条空闲线程。

那么问题就来了,中断一条空闲线程,也没说是一定中断正在阻塞的线程啊。如果A, B同时退出,有没有可能出现A中断B, B中断A,AB互相中断,从而没有线程去中断唤醒阻塞的线程呢?

答案仍然是,想多了……

假设A能走到这里,说明A已经从工作线程的集合workers里面移除了(processWorkerExit(Worker w, boolean completedAbruptly) 在tryTerminate()之前,已经将其移除)。那么A中断B,B来到这里中断,就不会在workers里面找到A了。

也就是说,退出的线程不能互相中断,我从集合中退出后,中断了你,你不能中断我,因为我已经退出集合,你只能中断别人。那么,即使有N个线程同时退出,至少在最后,也会有一条线程,会中断剩余的阻塞线程。

就像多米诺骨牌一样,中断信号就会被传播下去。

阻塞的C,D中的任意一条被中断唤醒后,又会重复step1的动作,周而复始,直到所有阻塞线程都被中断,唤醒。

这也是为什么在tryTerminate()里面,传入false,只需要中断任意一条空闲线程的原因。

想到这里,再次对Doug Lea心生钦敬(粤语)之情。这设计得也太妙了叭。

4、总结

ThreadPoolExecutor回收工作线程,一条线程getTask()返回null,就会被回收。

分两种场景。

1、未调用shutdown() ,RUNNING状态下全部任务执行完成的场景

线程数量大于corePoolSize,线程超时阻塞,超时唤醒后CAS减少工作线程数,如果CAS成功,返回null,线程回收。否则进入下一次循环。当工作者线程数量小于等于corePoolSize,就可以一直阻塞了。

2、调用shutdown() ,全部任务执行完成的场景

shutdown() 会向所有线程发出中断信号,这时有两种可能。

2.1)所有线程都在阻塞

中断唤醒,进入循环,都符合第一个if判断条件,都返回null,所有线程回收。

2.2)任务还没有完全执行完

至少会有一条线程被回收。在processWorkerExit(Worker w, boolean completedAbruptly)方法里会调用tryTerminate(),向任意空闲线程发出中断信号。所有被阻塞的线程,最终都会被一个个唤醒,回收。

作者:kingsleylam

链接:https://cnblogs.com/kingsleylam/p/11241625.html

请教java的线程池是如何回收线程的

工作线程回收需要满足三个条件:1) 参数allowCoreThreadTimeOut为true 2) 该线程在keepAliveTime时间内获取不到任务,即空闲这么长时间 3) 当前线程池大小 > 核心线程池大小corePoolSize。

线程池中的线程会消亡么

当线程池初始化之后的线程数为初始线程数,这个数量的线程永远都不会消失,除非线程池销毁。当初始线程全部被调用时,线程池会初始化新的线程数量,这个数量不超过最大线程数。当线程任务完成后得到释放,空闲的线程会按照配置的线程寿命周期时间逐渐销毁,恢复到初始线程数的线程数量。

面试突击29:说一下线程池7个参数的含义?

空闲线程存活时间指的是线程池中没有任务时,会销毁一些线程,销毁的线程数等于最大线程数减去核心线程数,如同短工在任务完成后的待岗时间。时间单位参数则描述了空闲线程存活时间的具体单位,例如是秒、分钟或小时。阻塞队列是线程池存放任务的队列,用于存储待执行的任务,常见的LinkedBlockingQueue适用于线...

web服务器项目常见面试题目(C++)——线程池相关

线程池中的工作线程并非持续等待,而是阻塞在请求队列是否为空的条件上。处理完任务后,线程会根据队列状态进入待命或竞争状态。处理高并发时,项目通过子线程循环和资源自动回收,确保任务及时响应。如果遇到长时间占用线程的情况,可设置处理超时策略来防止影响后续请求。在多线程环境中,线程池使用锁(如读...

线程池的参数有哪些

当超过这个时间后,闲置的线程会被终止以回收资源。这两个参数共同决定了空闲线程的回收策略,有助于在保障系统处理能力的同时,避免不必要的资源占用。其中,timeUnit用于定义存活时间的单位。合理设置这两个参数有助于平衡系统的性能和资源消耗。除了上述参数外,线程池还可能包括其他配置参数,如队列策略、...

面试官最爱问:CPU100%如何处理?

有时候,只是一个死循环在作祟。 有时候,是死锁导致的。 有时候,代码中有不必要的同步块。 有时候,是大量计算密集型任务在运行。 有时候,是线程数过多引起的。 有时候,是频繁的上下文切换。 有时候,是内存不足的问题。 有时候,是频繁的垃圾回收。 有时候,是内存泄漏导致的。 等等。导致CPU...

线程池中空闲的线程处于什么状态?

状态的线程有可能正在执行,也有可能正在等待着CPU为它分配执行时间。3)无限期等待(Waiting):处于这种状态的线程不会被分配CPU执行时间,它们要等待被 其他线程显式地唤醒。以下方法会让线程陷入无限期的等待状态:●没有设置Timeout参数的Object.wait()方法。●没有设置Timeout参数的Thread.join()...

面试突击30:线程池是如何执行的?拒绝策略有哪些?

线程池执行流程与拒绝策略详解当任务涌入线程池,它的执行过程与拒绝策略是核心话题。首先,让我们探索线程池如何处理新任务:当execute()方法接收到任务时,它会检查几个关键点。如果当前在线线程数未满核心线程数,会新建线程执行;若任务队列未满,将任务放入等待;若线程数接近最大值,会根据策略决定...

面试突击30:线程池是如何执行的?拒绝策略有哪些?

线程池会首先检查线程数量是否超过核心线程数量,若未超过则创建新线程执行任务;若已达到核心线程数量上限,线程池会判断任务队列是否已满,若未满则将任务加入队列等待执行,若已满则再判断线程数量是否超过最大值,若未超过则创建新线程执行此任务,若已超过最大值,则线程池将执行拒绝策略。线程池拒绝...

Java线程池中的核心线程是如何被重复利用的

而通过线程池我们可以做到复用线程,任务有多个,但执行任务的线程可以通过线程池来复用,这样减少了创建线程的开销,系统资源利用率得到了提升。 降低管理线程的难度。多线程环境下对线程的管理是最容易出现问题的,而线程池通过框架为我们降低了管理线程的难度。我们不用再去担心何时该销毁线程,如何最大限度的避免多线程的...

线程与多线程线程池 如何从线程池中获取线程 线程池默认多少个线程 java停止线程池中的线程 java多线程和线程池 线程池多线程实现 多线程线程池 线程和线程池 线程和线程池区别
声明声明:本网页内容为用户发布,旨在传播知识,不代表本网认同其观点,若有侵权等问题请及时与本网联系,我们将在第一时间删除处理。E-MAIL:11247931@qq.com
独立显卡与集成显卡可以同时运用吗 KSCAT瞌睡猫和LEPOW乐泡的移动电源,样子差不多,价格也差不多,选哪个... lepow充电宝是不是名牌 中国最好的充电宝牌子是什么? 百度商城,财富值明明足够,为什么兑换时显示财富值不足??? 百度知道上面的兑换物品乐泡移动电源是真吗?质量好不好?有谁兑换... 说说你认为哪种鸭脖比较好吃吧? 哪个品牌鸭脖好 关于工行的电子商务和对外转帐功能的疑问,请帮忙! 工行的卡在网上注册网上银行能不能使用转帐支付功能?没有去柜台办理的... 多达100是什么意思? as much as 与as many as 被讹诈的交通事故全责方有什么应对策略 交通事故全责方遭后期讹诈如何应对 认了全责后续有啥麻烦 认全责后期避免讹诈怎么做-公路资讯 禅宗道埸适合种什麼植物? 寺院能种月季吗? 寺院种什么品种的竹子 北京消费券在哪里领 京东消费券怎么领取?领取入口在哪里?有哪些城市?怎么用? 北京消费券怎么领_北京发放122亿元消费券领取方法 京东推出“北京绿色消费券”专区 买好物可领大额券 京东北京券非本地咋领 怎么领北京消费券啊? 七国的领土现在分布在哪些省? 战国时期七国分别在哪个省份 1平方的铜线能带多少千瓦? 工伤保险由谁支付赔偿费 10mm2能带多少千瓦 工伤保险待遇支付单位还是个人? 大航海时代4最强战舰排名 python最多创建多少个线程(2023年最新整理) 线程池执行过程中遇到异常会发生什么?怎样处理? 大航海时代4里最厉害的战船是英国伦敦无敌战舰吗 深圳的自考本科流程是什么? 深圳市自考学分怎么算的? 从昆明自驾去西双版纳沿途有什么好玩的地方 爱你要留的繁体字怎么写? 爱你:-*静 的繁体字怎么写?? 夫妻经常吵架风水化解,夫妻总吵架的风水原因 夫妻总吵架是因为这风水 夫妻总吵架的风水原因 夫妻总吵架的风水原因 家里总吵架风水 夫妻吵架风水破解方法 谷歌浏览器怎么启动Flash插件? 怎样在谷歌浏览器中开启Flash插件? 她是雪地捡回的弃婴,爹娘收养她的目的,是替姐姐嫁做棋子,她该怎么... 追星的粉丝是什么到底什么是追星的粉丝 什么样的粉丝才是理智的追星族呢? 为什么粉丝总有一种“哥哥只有我们”的心态?