关于多线程中抛异常的这个面试题我再说最后一次!

作者 : 开心源码 本文共5453个字,预计阅读时间需要14分钟 发布时间: 2022-05-14 共185人阅读

一道面试题

我一年前写过这篇文章《有的线程它死了,于是它变成一道面试题》,这是早期作品,遣词造句,排版行文都有一点稚嫩,但是承蒙厚爱,还是有很多人看过。

甚至已经进入了某网红公司的面试题库里面。

本文相当于是对上面这篇文章的一个补充。

现在先回顾一下这篇文章抛出的问题和问题的答案:

一个线程池中的线程异常了,那么线程池会怎样解决这个线程?

这个题是我遇到的一个真实的面试题,当时并没有答复的很好。而后通过上面的文章,我在源码中寻觅到了答案。

先给大家看两个案例。

sayHi 方法是会抛出运行时异常的。

当执行方式是 execute 方法时,在控制台会打印堆栈异常:

当执行方式是 submit 方法时,在控制台不会打印堆栈异常:

那么怎样获取这个 submit 方法提交时的异常信息呢?

得调用返回值 future 的 get 方法:

具体起因,我在之前的文章里面详细分析过,就不赘述了,直接看结论:

而后一个读者找我聊天,说为什么他这样写,通过 future.get 方法没有抛出异常呢,和我文章里面说的不一样呢?

我说:那一定是你操作不对,你把代码发给我看看。

而后我收到了一份这样的代码:

public class ExecutorsTest {    public static void main(String[] args) {        ThreadPoolExecutor executorService = new ThreadPoolExecutor(2, 2,                30, TimeUnit.SECONDS, new ArrayBlockingQueue<>(10));        Future future = executorService.submit(() -> {            try {                sayHi("submit");            } catch (Exception e) {                System.out.println("sayHi Exception");                e.printStackTrace();            }        });        try {            future.get();        } catch (Exception e) {            System.out.println("future.get Exception");            e.printStackTrace();        }    }    private static void sayHi(String name) throws RuntimeException {        String printStr = "【thread-name:" + Thread.currentThread().getName() + ",执行方式:" + name + "】";        System.out.println(printStr);        throw new RuntimeException(printStr + ",我异常啦!哈哈哈!");    }}

这个程序的输出结果是这样的:

我寻思这没毛病呀,这不是很正常吗?不就是应该这样输出吗?

那个哥们说:和你说的不一样啊,你说的是调用 future.get 方法的时候会抛出异常的?我这里并没有输出“future.get Exception”,说明 future.get 方法没有抛出异常。

我答复到:你这不是把会抛出运行时异常的 sayHi 方法用 try/catch 代码块包裹起来了吗?异常在子线程里面就解决完了,也就不会封装到 Future 里面去了。你把 try/catch 代码块去掉,异常就会封装到 Future 里面了。

过了一小会,他应该是试验完了,又找过来了。

他说:牛逼呀,的确是这样的。那你的这个面试题是有问题的啊,形容不清楚,正确的形容应该是一个线程池中的线程抛出了未经捕获的运行时异常,那么线程池会怎样解决这个线程?

看到他的这个回复的时候,我竟然鼓起掌来,这届读者真是太严格了!但是他说确实实是没有错,严谨点好。

他还追问到:怎样实现的呢?为什么当 submit 方法提交任务的时候,子线程捕获了异常,future.get 方法就不抛出异常了呢?

其实听到这个问题的时候都把我干懵了。

这问法,难道你是想再抛一次异常出来?

其实大家按照正常的思维去想,都能知道假如子线程捕获了一次,future.get 方法就不应该抛出异常了。

所以,现在的问题是,这个小小的功能,在线程池里面是怎样实现的?

现在的面试题在原来的基础上再加一层:

好,你说当执行方法是 submit 的时候,假如子线程抛出未经捕获的运行时异常,将会被封装到 Future 里面?那么假如子线程捕获了异常,该异常还会封装到 Future 里面吗?是怎样实现的呢

寻觅答案-FUTURE

来,一起去源码里面寻觅答案。

现在是用 submit 的方式往线程池里面提交任务,而执行的这个任务会抛出运行时异常。

对于抛出的这个异常,我们分为两种情况:

  • 子线程中捕获了异常,则调用返回的 future 的 get 方法,不会抛出异常。

  • 子线程中没有捕获异常,则调用返回的 future 的 get 方法,会抛出异常。

两种情况都和 future.get 方法有关,那我们就从这个方法的源码入手。

这个 Future 是一个接口:

而这个接口有非常多的实现类。我们找哪个实现类呢?

就是下面这个实现类:

java.util.concurrent.FutureTask

至于是怎样找到它的,你慢慢往后看就知道了。

先看看 FutureTask 的 get 方法:

get 方法的逻辑很简单,首先判断当前状态能否已完成,假如不是,则进入等待,假如是,则进入 report 方法。

一进 get 方法,我们就看到了 state 这个东西,这是 FutureTask 里面一个非常重要的东西:

在 FutureTask 里面,一共有 7 种状态。这 7 种状态之间的流转关系已经在注释里面写清楚了。

状态之间只会按照这四个流程去流转。

所以,一目了然,一个任务的终态有四种:NORMAL、EXCEPTIONAL、CANCELLED、INTERRUPTED。

而我们主要关心 NORMAL、EXCEPTIONAL。

所以再回头看看 get 方法:

假如当前状态是小于 COMPLEING 的。

也就是当前状态只能是 NEW 或者者 COMPLEING,总之就是任务还没有完成。所以进入 awaitDone 方法。这个方法不是本文关心的地方,接着往下看。

程序能往下走,说明当前的状态一定是下面圈起来的状态中的某一个:

记住这几种状态,而后看这个 report 方法:

这个方法是干啥的?

注解说的很清楚了:对于已经完成了的 task,返回其结果或者者抛出异常。

这里面的逻辑就很简单了,把 outcome 变量赋值给 x 。

而后判断当前状态,假如是 NORMAL,即 2,说明正常完成,直接返回 x。

假如是大于等于 CANCELLED,即大于等于 4 ,即这几种状态,就抛出 CancellationException。

剩下的情况就抛出 ExecutionException。

而这个“剩下的情况”是什么情况?

不就只剩下一个 EXCEPTIONAL 的情况了。

所以,经过前面的形容,我们可以总结一下。

当 FutureTask 的 status 为 NORMAL 时正常返回结果,当 status 为 EXCEPTIONAL 时抛出异常。

而当终态为 NORMAL 或者者 EXCEPTIONAL 时,按照注释形容,状态的流程只能是这样的:

那么究竟是不是这样的呢?

这就需要我们去线程池里面验证一下了。

寻觅答案-线程池

先答复上一节的一个问题:我怎样知道是看 Future 这个接口的 FutureTask 这个实现类的:

submit 方法提交的时候把任务包裹了一层,就是用 FutureTask 包裹的:

可以看到,FutureTask 的构造方法里面默认了状态为 NEW。

而后直接在 runWorker 方法的 task.run 方法处打上断点:

这个 task 是一个 FutureTask,所以 run 方法其实是 FutureTask 的 run 方法。

跟着断点进去之后,就是 FutureTask 的 run 方法:

答案都藏在这个方法里面。

java.util.concurrent.FutureTask#run

标号为 ① 的地方是执行我们的任务,call 的就是示例代码里面的 sayHi 方法。

假如提交的任务( sayHi 方法)抛出的运行时异常没有被捕获,则会在标号为 ② 的这个 catch 里面被捕获。而后执行标号为 ② 的这个代码。

假如提交的任务( sayHi 方法)捕获了运行时异常,则会进入标号为 ③ 的这个逻辑里面。

我们分别看一下标号为 ② 和 ③ 的逻辑:

首先,两个方法都是先进行一个 cas 的操作,把当前 FutureTask 的 status 字段从 NEW 修改为 COMPLETING 。

完成了状态流转的这一步:

注意这里,假如 cas 操作失败了,则不会进行任何操作。

cas 操作失败了,说明什么呢?

说明当前的状态是 CANCELLED 或者者 INTERRUPTING 或者者 INTERRUPTED。

也就是这个任务被取消了或者者被中断了。

那还设置结果干啥,没有任何卵用,对不对。

假如 cas 操作成功,接着往下看,可以看到尽管入参不一样了,但是都赋给了 outcome 变量,这个变量,在上一节的 report 方法出现过,还记得吗?能不能呼应上?

接下来就是状态接着往下流转。

set 方法表示正常结束,状态流转到 NORMAL。

setException 方法表示任务出现异常,状态流转到 EXCEPTIONAL。

所以经过 FutureTask 的 run 方法后,假如任务没有被中断或者者取消,则会通过 setException 或者者 set 方法完成状态的流转和 outcome 参数的设置:

而究竟是调用 setException 方法还是 set 方法,取决于标号为 ① 的地方能否会抛出异常。

即取决于任务体能否会抛出异常。

假设 sayHi 方法是这样的,会抛出运行时异常:

而通过 submit 方法提交任务时写法分别如下:

假如是标号为 ① 的写法,则会进入 setException 方法。

假如是标号为 ② 的写法,则会进入 set 方法。

所以,你现在再回去看看这个题目:

当执行方法是 submit 的时候,假如子线程抛出未经捕获的运行时异常,将会被封装到 Future 里面,那么假如子线程捕获了异常,该异常还会封装到 Future 里面吗?是怎样实现的呢?

现在是不是很清晰了。

假如子线程捕获了异常,该异常不会被封装到 Future 里面。是通过 FutureTask 的 run 方法里面的 setException 和 set 方法实现的。在这两个方法里面完成了 FutureTask 里面的 outcome 变量的设置,同时完成了从 NEW 到 NORMAL 或者者 EXCEPTIONAL 状态的流转。

线程池拒绝异常

写文章的时候我忽然又想到一个问题。

不管是用 submit 还是 execute 方法往线程池里面提交任务,假如因为线程池满了,导致抛出拒绝异常呢?

RejectedExecutionException 异常也是一个 RuntimeException:

那么对于这个异常,假如我们不进行捕获,是不是也不会打印呢?

假设你不知道这个问题,你就分析一下,从会和不会中猜一个呗。

我猜是会打印的。

由于假设让我来提供一个这样的功能,因为线程池饱和了而拒绝了新任务的提交,我一定得给使用方一个提醒。告诉他有的任务因为线程池满了而没有提交进去。

不然,使用者自己排查到这个问题后,一定会说一声:这什么傻逼玩意,把异常给吞了?

来,搞个 Demo 验证一下:

我们定义的这个线程池最大容量是 7 个任务。

在循环体中扔 10 个比较耗时的任务进去。有 3 个任务它解决不了,那么一定是会触发拒绝策略的。

你觉得这个程序运行后会在控制台打印异常日志吗?会打印几次呢?

看一下运行结果:

抛出了一次异常,执行完成了 7 个任务。

我们并没有捕获异常,打印堆栈信息的相关代码,那么这个异常是谁打印的?

假如你没有捕获异常,JVM 会帮你调用这个方法:

而这个方法里面,会输出错误堆栈:

所以,当我们没有捕获异常的时候,会在这里打印一次堆栈日志。

而当我们捕获了异常之后,改成这样:

再次运行:

10 个任务,三次异常,完成了 7 个任务。

也不会让 JVM 触发 dispatchUncaughtException 方法了。

而这个异常日志的打印和哪种方式提交任务没有关系,不管哪种,只需你没有捕获异常,则都会触发 dispatchUncaughtException 方法。

终极答案

上面说这个例子,其实我就是想引出终极答案。

终极答案就是:dispatchUncaughtException 方法。

为什么这样说呢?

我们现在把情况分为三种。

第一种:submit 方法提交一个会抛出运行时异常的任务,捕不捕获异常都可以。

第二种:execute 方法提交一个会抛出运行时异常的任务,不捕获异常。

第三种:submit 或者者 execute 提交,让线程池饱和之后抛出拒绝异常,代码没有捕获异常。

第一种情况,无论如何都不会触发 dispatchUncaughtException 方法。由于 submit 方法提交,不管你捕获与否,源码里面都帮你捕获了:

第二种情况,假如不捕获异常,会触发 dispatchUncaughtException 方法,由于 runWorker 方法的源码里面尽管捕获了异常,但是又抛出去了:

而我们自己没有捕获,所以会触发 dispatchUncaughtException 方法。

第三种情况,和第二种其实是一样的。没有捕获,就会触发。

那么我现在给你一段这样的代码:

你一定知道这是会抛出异常的吧。

就像这样式儿的:

我们完全没有打印日志的代码吧?

那你现在知道控制台这个异常信息是怎样来的了不?

是不是平常根本就没有注意这个点。

作者:why技术
链接:https://mp.weixin.qq.com/s/aOlScg5sfQ4JvHzcRFqeyQ

说明
1. 本站所有资源来源于用户上传和网络,如有侵权请邮件联系站长!
2. 分享目的仅供大家学习和交流,您必须在下载后24小时内删除!
3. 不得使用于非法商业用途,不得违反国家法律。否则后果自负!
4. 本站提供的源码、模板、插件等等其他资源,都不包含技术服务请大家谅解!
5. 如有链接无法下载、失效或广告,请联系管理员处理!
6. 本站资源售价只是摆设,本站源码仅提供给会员学习使用!
7. 如遇到加密压缩包,请使用360解压,如遇到无法解压的请联系管理员
开心源码网 » 关于多线程中抛异常的这个面试题我再说最后一次!

发表回复