面试官：线程池执行过程中遇到异常会发生什么，怎样处理？

水深无声 2022-09-15 14:00 138阅读 0赞

**点击关注公众号，Java干货****及时送达**![e05bbec488da8f43bab961a6f6f3ab02.png][]

#### 线程遇到未处理的异常就结束了 ####

这个好理解，当线程出现未捕获异常的时候就执行不下去了，留给它的就是垃圾回收了。

#### 线程池中线程频繁出现未捕获异常 ####

[当线程池中线程频繁出现未捕获的异常，那线程的复用率就大大降低了，需要不断地创建新线程。][Link 1]

[做个实验：][Link 1]

public class ThreadExecutor {
    
     private ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1, 1, 60, TimeUnit.SECONDS,
       new ArrayBlockingQueue<>(200), new ThreadFactoryBuilder().setNameFormat("customThread %d").build());
    
     @Test
     public void test() {
      IntStream.rangeClosed(1, 5).forEach(i -> {
       try {
        Thread.sleep(100);
       } catch (InterruptedException e) {
        e.printStackTrace();
       }
       threadPoolExecutor.execute(() -> {
         int j = 1/0;
      });});
     }
    }

[新建一个只有一个线程的线程池，每隔0.1s提交一个任务，任务中是一个1/0的计算。][Link 1]

Exception in thread "customThread 0" java.lang.ArithmeticException: / by zero
     at thread.ThreadExecutor.lambda$null$0(ThreadExecutor.java:25)
     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
     at java.lang.Thread.run(Thread.java:748)
    Exception in thread "customThread 1" java.lang.ArithmeticException: / by zero
     at thread.ThreadExecutor.lambda$null$0(ThreadExecutor.java:25)
     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
     at java.lang.Thread.run(Thread.java:748)
    Exception in thread "customThread 2" java.lang.ArithmeticException: / by zero
     at thread.ThreadExecutor.lambda$null$0(ThreadExecutor.java:25)
     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
     at java.lang.Thread.run(Thread.java:748)
    Exception in thread "customThread 3" java.lang.ArithmeticException: / by zero
     at thread.ThreadExecutor.lambda$null$0(ThreadExecutor.java:25)
     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
     at java.lang.Thread.run(Thread.java:748)
    Exception in thread "customThread 4" java.lang.ArithmeticException: / by zero
     at thread.ThreadExecutor.lambda$null$0(ThreadExecutor.java:25)
     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
     at java.lang.Thread.run(Thread.java:748)
    Exception in thread "customThread 5" java.lang.ArithmeticException: / by zero
     at thread.ThreadExecutor.lambda$null$0(ThreadExecutor.java:25)
     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
     at java.lang.Thread.run(Thread.java:748)

[可见每次执行的线程都不一样，之前的线程都没有复用。原因是因为出现了未捕获的异常。][Link 1]

[**我们把异常捕获试试：**][Link 1]

customThread 0 / by zero
    customThread 0 / by zero
    customThread 0 / by zero
    customThread 0 / by zero
    customThread 0 / by zero

[可见当异常捕获了，线程就可以复用了。另外， 多线程系列面试题和答案全部整理好了，微信搜索Java技术栈，在后台发送：面试，可以在线阅读。][Link 1]

#### 问题来了，我们的代码中异常不可能全部捕获 ####

如果要捕获那些没被业务代码捕获的异常，可以设置Thread类的`uncaughtExceptionHandler`属性。这时使用`ThreadFactoryBuilder`会比较方便，`ThreadFactoryBuilder`是guava提供的ThreadFactory生成器。

new ThreadFactoryBuilder()
    .setNameFormat("customThread %d")
    .setUncaughtExceptionHandler((t, e) -> System.out.println(t.getName() + "发生异常" + e.getCause()))
    .build()

修改之后：

public class ThreadExecutor {
    
     private static ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1, 1, 60, TimeUnit.SECONDS,
       new ArrayBlockingQueue<>(200),
       new ThreadFactoryBuilder()
         .setNameFormat("customThread %d")
         .setUncaughtExceptionHandler((t, e) -> System.out.println("UncaughtExceptionHandler捕获到：" + t.getName() + "发生异常" + e.getMessage()))
         .build());
    
     @Test
     public void test() {
      IntStream.rangeClosed(1, 5).forEach(i -> {
       try {
        Thread.sleep(100);
       } catch (InterruptedException e) {
        e.printStackTrace();
       }
    
       threadPoolExecutor.execute(() -> {
        System.out.println("线程" + Thread.currentThread().getName() + "执行");
        int j = 1 / 0;
       });
      });
     }
    }

线程customThread 0执行
    UncaughtExceptionHandler捕获到：customThread 0发生异常/ by zero
    线程customThread 1执行
    UncaughtExceptionHandler捕获到：customThread 1发生异常/ by zero
    线程customThread 2执行
    UncaughtExceptionHandler捕获到：customThread 2发生异常/ by zero
    线程customThread 3执行
    UncaughtExceptionHandler捕获到：customThread 3发生异常/ by zero
    线程customThread 4执行
    UncaughtExceptionHandler捕获到：customThread 4发生异常/ by zero

可见，结果并不是我们想象的那样，线程池中原有的线程没有复用！所以通过`UncaughtExceptionHandler`想将异常吞掉使线程复用这招貌似行不通。它只是做了一层异常的保底处理。

推荐一个 Spring Boot 基础教程及实战示例：https://www.javastack.cn/categories/Spring-Boot/

**将excute改成submit试试**

public class ThreadExecutor {
    
     private static ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1, 1, 60, TimeUnit.SECONDS,
       new ArrayBlockingQueue<>(200),
       new ThreadFactoryBuilder()
         .setNameFormat("customThread %d")
         .setUncaughtExceptionHandler((t, e) -> System.out.println("UncaughtExceptionHandler捕获到：" + t.getName() + "发生异常" + e.getMessage()))
         .build());
    
     @Test
     public void test() {
      IntStream.rangeClosed(1, 5).forEach(i -> {
       try {
        Thread.sleep(100);
       } catch (InterruptedException e) {
        e.printStackTrace();
       }
    
       Future<?> future = threadPoolExecutor.submit(() -> {
        System.out.println("线程" + Thread.currentThread().getName() + "执行");
        int j = 1 / 0;
       });
       try {
        future.get();
       } catch (InterruptedException e) {
        e.printStackTrace();
       } catch (ExecutionException e) {
        e.printStackTrace();
       }
      });
     }
    }

线程customThread 0执行
    java.util.concurrent.ExecutionException: java.lang.ArithmeticException: / by zero
    线程customThread 0执行
    java.util.concurrent.ExecutionException: java.lang.ArithmeticException: / by zero
    线程customThread 0执行
    java.util.concurrent.ExecutionException: java.lang.ArithmeticException: / by zero
    线程customThread 0执行
    java.util.concurrent.ExecutionException: java.lang.ArithmeticException: / by zero
    线程customThread 0执行
    java.util.concurrent.ExecutionException: java.lang.ArithmeticException: / by zero

通过submit提交线程可以屏蔽线程中产生的异常，达到线程复用。当get()执行结果时异常才会抛出。

原因是通过submit提交的线程，当发生异常时，会将异常保存，待`future.get();`时才会抛出。最新面试题整理好了，点击Java面试库小程序在线刷题。

这是Futuretask的部分`run()`方法，[看setException：][setException]

public void run() {
        try {
            Callable<V> c = callable;
            if (c != null && state == NEW) {
                V result;
                boolean ran;
                try {
                    result = c.call();
                    ran = true;
                } catch (Throwable ex) {
                    result = null;
                    ran = false;
                    setException(ex);
                }
                if (ran)
                    set(result);
            }
        } 
    }
    
    protected void setException(Throwable t) {
        if (UNSAFE.compareAndSwapInt(this, stateOffset, NEW, COMPLETING)) {
            outcome = t;
            UNSAFE.putOrderedInt(this, stateOffset, EXCEPTIONAL); // final state
            finishCompletion();
        }
    }

[将异常存在outcome对象中，没有抛出，再看get方法：][setException]

public V get() throws InterruptedException, ExecutionException {
        int s = state;
        if (s <= COMPLETING)
            s = awaitDone(false, 0L);
        return report(s);
    }
    private V report(int s) throws ExecutionException {
        Object x = outcome;
        if (s == NORMAL)
            return (V)x;
        if (s >= CANCELLED)
            throw new CancellationException();
        throw new ExecutionException((Throwable)x);
    }

[当outcome是异常时才抛出。][setException]

#### [总结][setException] ####

[1、线程池中线程中异常尽量手动捕获][setException]

[2、通过设置ThreadFactory的UncaughtExceptionHandler可以对未捕获的异常做保底处理，通过execute提交任务，线程依然会中断，而通过submit提交任务，可以获取线程执行结果，线程异常会在get执行结果时抛出。][setException]

本文链接：https://blog.csdn.net/weixin\_37968613/article/details/108407774

![1105242ff5d31eb9e206a9e933129058.gif][]

[![eb9eac2bfd115e2a696c76bfffe86de0.png][]][eb9eac2bfd115e2a696c76bfffe86de0.png 1]

[![60760d69a580a699cd1013a10be26780.png][]][60760d69a580a699cd1013a10be26780.png 1]

[![e82d4fb951b958c68f937e399e8783ae.png][]][e82d4fb951b958c68f937e399e8783ae.png 1]

[![3ed7602b4367898d8fb2a75252b861a5.png][]][3ed7602b4367898d8fb2a75252b861a5.png 1]

[![ae102ced63405abed3c148f41856e2b4.png][]][ae102ced63405abed3c148f41856e2b4.png 1]

[![3853853a33cdc4e376bc6c24f1fe2d6b.png][]][3853853a33cdc4e376bc6c24f1fe2d6b.png 1]

[![ffbbaffaf2df485fba4524bd9a767d92.png][]][ffbbaffaf2df485fba4524bd9a767d92.png 1]

**关注Java技术栈看更多干货**

![37428faf2e8e725599353bad744ea313.png][]

![def7faa6ae710ca60f2210946d878750.gif][]

获取 Spring Boot 实战笔记！

[e05bbec488da8f43bab961a6f6f3ab02.png]: /images/20220828/3c773064921443abacad400ac039b94e.png
[Link 1]: http://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw==&mid=2247542384&idx=2&sn=4f1148b7fc0090760ba0e8ef4c299ac1&chksm=eb50a346dc272a50baca4f3f935323612c0ce4283599e87550276336dcc79b9bd6bde2f627df&scene=21#wechat_redirect
[setException]: http://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw==&mid=2247535563&idx=2&sn=2f28d811947f61f9690336b433831c19&chksm=eb50cefddc2747ebf647ce65467630ba9f010b1558f9bd5e5156700bcdc17baf788ad0c94a86&scene=21#wechat_redirect
[1105242ff5d31eb9e206a9e933129058.gif]: /images/20220828/b66f06b5e57a4958827c9f3e9bd09088.png
[eb9eac2bfd115e2a696c76bfffe86de0.png]: /images/20220828/569160828eb947d7a5b14778cf3b9524.png
[eb9eac2bfd115e2a696c76bfffe86de0.png 1]: https://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw==&mid=2247545151&idx=1&sn=3011ea02ff69b7d841dc86caaa5666b7&scene=21#wechat_redirect
[60760d69a580a699cd1013a10be26780.png]: /images/20220828/a7b4bc2affbb4750bfa1bcad32ca25f6.png
[60760d69a580a699cd1013a10be26780.png 1]: https://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw==&mid=2247545678&idx=1&sn=a430fb2e260c200dc79fe37f5382868e&scene=21#wechat_redirect
[e82d4fb951b958c68f937e399e8783ae.png]: /images/20220828/d96dfbdccb394bb4a99376ce0ae5a97f.png
[e82d4fb951b958c68f937e399e8783ae.png 1]: https://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw==&mid=2247545350&idx=1&sn=c1bbc0bd21799c3d936d59ecdaf97f8e&scene=21#wechat_redirect
[3ed7602b4367898d8fb2a75252b861a5.png]: /images/20220828/25b92791cca942bb819b9f92554f9df9.png
[3ed7602b4367898d8fb2a75252b861a5.png 1]: https://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw==&mid=2247539795&idx=1&sn=1efca511169265e8146e90db220159d5&scene=21#wechat_redirect
[ae102ced63405abed3c148f41856e2b4.png]: /images/20220828/a291f9adca1942f3bdcc3ced4d7e674f.png
[ae102ced63405abed3c148f41856e2b4.png 1]: https://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw==&mid=2247542231&idx=1&sn=75ab147414255cc18c26b03746833be8&scene=21#wechat_redirect
[3853853a33cdc4e376bc6c24f1fe2d6b.png]: /images/20220828/36ce458c27ef422687e48e4dd4b05363.png
[3853853a33cdc4e376bc6c24f1fe2d6b.png 1]: https://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw==&mid=2247537730&idx=1&sn=3869e164e482b838671fa8896cb33cdb&scene=21#wechat_redirect
[ffbbaffaf2df485fba4524bd9a767d92.png]: /images/20220828/3de6e0bc58c14a1e995d8186b6e24605.png
[ffbbaffaf2df485fba4524bd9a767d92.png 1]: https://mp.weixin.qq.com/s?__biz=MzI3ODcxMzQzMw==&mid=2247540947&idx=1&sn=a4941f93acb4ee551534a4a1f57d9376&scene=21#wechat_redirect
[37428faf2e8e725599353bad744ea313.png]: /images/20220828/88f94d19b9d24e3dbfb6988d933644f1.png
[def7faa6ae710ca60f2210946d878750.gif]: /images/20220828/8e44eb27e2b0443b8d351103a23d02b2.png