Java多线程之捕获子线程中的异常

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

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

首先咱们咱们先实现Thread.UncaughtExceptionHandler接口:ide

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
性能

很明显,程序能够运行,说明异常被捕获了,而且也是咱们所抛出的异常,但愿对你们有所帮助。测试