zoukankan      html  css  js  c++  java
  • Java多线程之捕获子线程中的异常---面试经

    在某些场景下,我们经常需要使用多线程来执行任务提高性能,但是我们知道正常的主线程是无法处理子线程的异常的,一旦出现异常就会传播到控制台。这个时候我们需要在线程里面处理异常怎么办呢,我们可以使用Executor来处理。

    在Java5中新加入了一个Thread.UncaughtExceptionHandler接口,这个接口可以让我们在每个Thread对象上都附着一个异常处理器,它的unacughtException()方法线程因未捕获的异常而死亡时被调用。

    首先我们我们先实现Thread.UncaughtExceptionHandler接口:

    class myUncaughtExceptionhandler implements Thread.UncaughtExceptionHandler{//实现线程异常处理接口
    
        @Override
        public void uncaughtException(Thread t, Throwable e) {
            System.out.println("cause"+ e);
        }
    }

    我们在自定义一个线程工厂:

    class HandlerThreadFactory implements ThreadFactory{
        @Override
        public Thread newThread(Runnable r) {
            System.out.println(this+"create new thread");
            Thread t = new Thread(r);
            System.out.println("create"+t);
            t.setUncaughtExceptionHandler(new myUncaughtExceptionhandler());//设置我们自定义的异常处理
            //Thread.setDefaultUncaughtExceptionHandler();也可使用此方法设置默认的处理器
            System.out.println("eh="+t.getUncaughtExceptionHandler());
            return t;
        }
    }

    最后我们实现一个Runnable接口,并在run方法中抛出一个异常:

    class MyThread implements Runnable {
        @Override
        public void run() {
            Thread t = Thread.currentThread();
            System.out.println("run()"+ t);
            System.out.println("eh="+t.getUncaughtExceptionHandler());
            throw new RuntimeException();
        }
    }

    ok,我们再写个main方法来测试一些:

    public static void main(String[] args){
        ExecutorService exe = Executors.newCachedThreadPool(new HandlerThreadFactory());//使用我们自定义的ThreadFactory
        exe.execute(new MyThread());
    }

    运行结果如下图所示:

    concurrence.HandlerThreadFactory@14ae5a5create new thread
    createThread[Thread-0,5,main]
    eh=concurrence.myUncaughtExceptionhandler@7f31245a
    run()Thread[Thread-0,5,main]
    eh=concurrence.myUncaughtExceptionhandler@7f31245a
    concurrence.HandlerThreadFactory@14ae5a5create new thread
    createThread[Thread-1,5,main]
    eh=concurrence.myUncaughtExceptionhandler@154d7c22
    causejava.lang.RuntimeException

    很明显,程序可以运行,说明异常被捕获了,并且也是我们所抛出的异常,希望对大家有所帮助。

    消化于:https://blog.csdn.net/MaybeUnforgiven/article/details/72989497

  • 相关阅读:
    视频:JDBCRDD源码及自定义JDBCRDD的分区策略
    聊聊spark-submit的几个有用选项
    线性求第k大
    汇编基础 第一章_总线
    长度不超过n的连续最大和___优先队列
    ISAP
    次小生成树
    k短路
    求出欧拉回路,欧拉路径
    拓扑排序bfs_dfs
  • 原文地址:https://www.cnblogs.com/Ankermaker/p/8698394.html
Copyright © 2011-2022 走看看