Java多线程-捕获线程异常

墨蓝 2022-06-03 06:18 350阅读 0赞

主线程不能捕获到子线程的运行时异常RuntimeException。  
子线程RuntimeException对于invoke子线程的主线程会产生什么影响呢？主线程不受这个影响，不会处理这个RuntimeException，而且根本不能catch到这个异常。会继续执行自己的代码 :)  
所以得到结论：线程方法的异常只能自己来处理。

import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    public class ExeceptionThread implements Runnable { 
        @Override
        public void run() {
            throw new RuntimeException();
        }
    
        public static void main(String[] args) {
            try {
                ExecutorService exec = Executors.newCachedThreadPool();
                exec.execute(new ExeceptionThread());
            } catch (Exception e) {
                System.out.println("exeception has handled");
            }
        }
    }

输出：

> Exception in thread “pool-1-thread-1” java.lang.RuntimeException  
> at Thread.Exection.ExeceptionThread.run(ExeceptionThread.java:10)  
> at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)  
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)  
> at java.lang.Thread.run(Unknown Source)

**解决方法：通过设置默认异常捕获类捕获异常。**

> 给某个thread设置一个UncaughtExceptionHandler，可以确保在该线程出现异常时能通过回调UncaughtExceptionHandler接口的public void uncaughtException(Thread t, Throwable e) 方法来处理异常，这样的好处或者说目的是可以在线程代码边界之外（Thread的run()方法之外），有一个地方能处理未捕获异常。但是要特别明确的是：虽然是在回调方法中处理异常，但这个回调方法在执行时依然还在抛出异常的这个线程中！

import java.lang.Thread.UncaughtExceptionHandler;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    public class ExeceptionThread implements Runnable { 
        @Override
        public void run() {
            throw new RuntimeException();
        }
    
        public static void main(String[] args) {
            try {
                Thread thread = new Thread(new ExeceptionThread());
                // 默认异常捕获类。为所有的Thread设置一个默认的UncaughtExceptionHandler
                Thread.setDefaultUncaughtExceptionHandler(new UncaughtExceptionHandler() {
    
                    @Override
                    public void uncaughtException(Thread t, Throwable e) {
                        System.out.println("caught "+e);
                    }
                });
                ExecutorService exec = Executors.newCachedThreadPool();
                exec.execute(thread);
            } catch (Exception e) {
                System.out.println("exeception has handled");
            }
        }
    }

输出：

> caught java.lang.RuntimeException

**如果不使用ExecutorService，则直接对thread设置异常捕获类就行，把上面代码稍微改造一下：**

Thread thread = new Thread(new ExeceptionThread());
    // 这种捕获方式不适合ExecutorService
    thread.setUncaughtExceptionHandler(new UncaughtExceptionHandler() {
    
            @Override
            public void uncaughtException(Thread t, Throwable e) {
                System.out.println("caught "+e);
            }
        });
    
    thread.start();

输出：

> caught java.lang.RuntimeException

**线程设计的理念：“线程的问题应该线程自己本身来解决，而不要委托到外部。”**