写点什么

一个线程池中的线程异常了,那么线程池会怎么处理这个线程?

发布于: 2020 年 09 月 22 日

有些线程它活着,但它躺在池中碌碌无为;

有的线程它死了,于是它变成一道面试题。

这次的文章,要从一次阿里巴巴的面试说起。

我记得那天是周一,刚刚经历过周末过的放松,干劲十足的我正在键盘上疯狂的输出。这时,我的手机响了起来,拿起一看,是来自杭州的电话,心想这次是要给我推荐股票呢还是要让我贷款呢。我接起了电话,准备调戏一番。那边响起一个声音:"你好,请问是xxx吗?这边是杭州阿里巴巴,现在有时间进行电话面试吗?"。说实在的,听完这句话后,我感觉我已经身在杭州,干劲十足的在杭州的阿里的工位上"修福报"。但是我现在正在疯狂输出,没有时间,于是我说:"不好意思,现在没有时间,可以约在今天晚上8点钟吗?"

晚上如约接到了电话。我们直奔主题,在你来我往中进行了友好的技术交流。具体的面试过程就不详述了,文末整理一套pdf版面试分享需要的朋友可以免费获取下。整个面试过程中,有这么一道题给我留下了深刻的印象:

一个线程池中的线程异常了,那么线程池会怎么处理这个线程?

需要说明一下,文中讨论的线程池都是Executors线程池。

对于Executors线程池我可以说是烂熟于心,因为工作中用的比较的多,阅读过其源码。也是我作为面试官时必问的几个范围之一,比如以下问题:

了解JDK Executors线程池吗?

知道JDK提供了哪些默认的实现吗?

看过阿里巴巴java开发手册吗?知道为啥不允许使用默认的实现吗?

你们没有用默认的吧?那来介绍一下你们自定义线程池的几个常用参数呗?

你这个几个参数的值是怎么得来的呀?算出来的?怎么算出来的?

线程池里面的任务是IO密集型的还是计算密集型的呢?

好,现在我们有一个自定义线程池了,来说一下你这个线程池的工作流程呗?

那你这个线程池满了怎么办呀?拒绝?咋拒绝?有哪些拒绝策略呢?

别紧张,随便说两个就行。

......

回到开始说的阿里巴巴java开发手册不允许使用默认实现,你回答说可能会引起OOM,那我们聊聊JVM吧

......



阿里巴巴java开发手册关于线程池创建的建议

这一系列关于线程池的连环炮,就是我作为面试官时必问的几个问题。别问为什么,因为我们的招聘JD上明确写了:熟悉多线程编程。而这些问题,我觉得是熟悉多线程编程的基础。这里我也不解答了,这种文章网上还是挺多的,可以去了解一下。

这块真的很重要,我也多次给我的小伙伴强调:





来吧,一起分析一波

好了现在回到阿里的面试官问我的这道面试题:

一个线程池中的线程异常了,那么线程池会怎么处理这个线程?

先说说我当时的回答,因为心里没底,我的回答很犹豫也很烂!如下:



我的回答总结起来三句话:

1.抛出堆栈异常               ---这句话对了一半!

2.不影响其他线程任务      ---这句话全对!

3.这个线程会被放回线程池---这句话全错!

测试用例写起来





再提供一个复制粘贴直接运行版本:

/** * @Author: why技术 * @Date: 2019/9/6 22:25 */public class ExecutorsTest { public static void main(String[] args) { ThreadPoolTaskExecutor executorService = buildThreadPoolTaskExecutor(); executorService.execute(() -> sayHi("execute")); executorService.submit(() -> sayHi("submit")); } private static void sayHi(String name) { String printStr = "【thread-name:" + Thread.currentThread().getName() + ",执行方式:" + name+"】"; System.out.println(printStr); throw new RuntimeException(printStr + ",我异常啦!哈哈哈!"); } private static ThreadPoolTaskExecutor buildThreadPoolTaskExecutor() { ThreadPoolTaskExecutor executorService = new ThreadPoolTaskExecutor(); executorService.setThreadNamePrefix("(公众号-why技术)-"); executorService.setCorePoolSize(5); executorService.setMaxPoolSize(10); executorService.setQueueCapacity(1000); executorService.setKeepAliveSeconds(30); executorService.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); executorService.initialize(); return executorService; }}

抛出堆栈异常为啥对了一半?

先让程序跑起来,我们用事实说话:



从执行结果我们看出

当执行方式是execute时,可以看到堆栈异常的输出。

当执行方式是submit时,堆栈异常没有输出。

那么我们怎么拿到submit执行方式的堆栈异常呢,看图说话:





所以,现在知道为什么回答:抛出堆栈异常只对了一半吧。

execute方法执行时,会抛出(打印)堆栈异常。

submit方法执行时,返回结果封装在future中,如果调用future.get()方法则必须进行异常捕获,从而可以抛出(打印)堆栈异常。

你以为这一部分写到这里就完事了?那不行啊,你心里没有一个疑问吗?为啥execute直接抛出异常,submit没有直接抛出异常呢?

源码之下无秘密:

当执行方式是executes时:

java.util.concurrent.ThreadPoolExecutor#runWorker中抛出了异常:





java.lang.ThreadGroup#uncaughtException进行了异常处理:





这个uncaughtException是何许人也,看java doc上咋说的:





这个方法是JVM调用的,我们只需要指定我们想要的处理方式即可。

那我们怎么指定呢:​​​​​​​

//直接new Thread()的时候Thread t = new Thread();t.setUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {public void uncaughtException(Thread t, Throwable e) {      //根据业务场景,做你想做的 }});​​​​​//线程池的时候:ExecutorService threadPool = Executors.newFixedThreadPool(1, r -> {Thread t = new Thread(r);t.setUncaughtExceptionHandler(   (t1, e) -> System.out.println("根据业务场景,做你想做的:" + e.getMessage())); return t;});

当执行方式是submit时:





其本质也是调用了execute方法,所以它还是回到java.util.concurrent.ThreadPoolExecutor#runWorker方法:



向前,继续跟进去看看:





java.util.concurrent.FutureTask#setException干啥了啊,瞅一眼:





深呼吸,整理好思路,我们马上走向最终的真相:





好了,第一个议题【抛出堆栈异常为啥对了一半?】讨论完毕。在源码里面走了一趟,现在我们可以给出这一部分的满分答案了。

不影响其他线程任务,回答正确

一部分我们直接上代码,运行起来看结果吧:





代码和运行结果是不会骗人的:

线程池中一个线程异常了后,不影响其他线程任务

大家注意线程名称这个细节:1,2,3,4,6。魔鬼都在细节里啊,这个点我下面会讲,先在这里把问题抛出来:我就纳闷了,怎么没有5啊?!

这个线程会被放回线程池为啥全错了?

我们去源码里面寻找答案:





让源码给出答案:





5号线程去哪里了?





new Worker()方法会告诉你:5去哪里了。





再配上这张由我这个灵魂画师亲自操刀画的图,一起食用,味道更佳:





现在我们知道为啥:我回答这个线程会被放回线程池为啥全错了吧。还附送你一个线程名称变化的细节,不客气,关注一下就好。

总结一下

当一个线程池里面的线程异常后:

当执行方式是execute时,可以看到堆栈异常的输出。

当执行方式是submit时,堆栈异常没有输出。但是调用Future.get()方法时,可以捕获到异常。

不会影响线程池里面其他线程的正常执行。

线程池会把这个线程移除掉,并创建一个新的线程放到线程池中。

不要背答案,要理解,要深入,上面说完后记得在问问面试官,需要我从源码的角度讲一讲吗?这逼装的,礼貌而不失风度。

以上,我关于《一个线程池中的线程异常了,那么线程池会怎么处理这个线程?》这个问题的见解就表达完毕,仅代表个人观点,欢迎有不同意见的小伙伴,一起讨论,一起进步。

9月跳槽季,我这里整理了2020年大型互联网公司面试常问的面试题和答案及面试经验总结,希望能给那些有需要朋友在求职路上起到帮助,拿到自己满意的offer。需要这一整套面试真题的朋友点赞此文后添加助手vx:bjmsb10,免费获取







用户头像

还未添加个人签名 2020.09.07 加入

还未添加个人简介

评论

发布
暂无评论
一个线程池中的线程异常了,那么线程池会怎么处理这个线程?