有些线程它活着，但它躺在池中碌碌无为；

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



正文开始



我记得那天是周一，刚刚经历过周末过的放松，干劲十足的我正在键盘上疯狂的输出。这时，我的手机响了起来，拿起一看，是来自杭州的电话，心想这次是要给我推荐股票呢还是要让我贷款呢。我接起了电话，准备调戏一番。





那边响起一个声音:"你好，请问是xxx吗？这边是杭州阿里巴巴，现在有时间进行电话面试吗?"。说实在的，听完这句话后，我感觉我已经身在杭州，干劲十足的在杭州的阿里的工位上"修福报"。但是我现在正在疯狂输出，没有时间，于是我说:"不好意思，现在没有时间，可以约在今天晚上8点钟吗?".



晚上如约接到了电话。我们直奔主题，在你来我往中进行了友好的技术交流。具体的面试过程就不详述了，后面有机会整理一份面试分享。整个面试过程中，有这么一道题给我留下了深刻的印象:



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



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

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



了解JDK Executors线程池吗?

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

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

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

线程池里面的任务是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;
    }
}



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

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



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



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

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

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



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



源码之下无秘密:



当执行方式是executes时:

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



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



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



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



那我们怎么指定呢:







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



向前，继续跟进去看看



java.util.concurrent.FutureTask#setException干啥了啊，瞅一眼：





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

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



代码和运行结果是不会骗人的:线程池中一个线程异常了后，不影响其他线程任务



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





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



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



让源码给出答案:







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





现在我们知道为啥：我回答这个线程会被放回线程池为啥全错了吧？



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

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

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

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

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



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



最后，再感叹一次



有的线程它死了，被抛弃，被回收，

但是它无怨无悔，



它凭借自己最后的一声呐喊

“为了新兄弟，移除我吧！”

最后，变成一道面试题。



我还没答上来。