在某些场景下,我们经常需要使用多线程来执行任务提高性能,但是我们知道正常的主线程是无法处理子线程的异常的,一旦出现异常就会传播到控制台。这个时候我们需要在线程里面处理异常怎么办呢,我们可以使用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()); }
运行结果如下图所示:
[email protected] new thread
createThread[Thread-0,5,main]
[email protected]
run()Thread[Thread-0,5,main]
[email protected]
[email protected] new thread
createThread[Thread-1,5,main]
[email protected]
causejava.lang.RuntimeException
很明显,程序可以运行,说明异常被捕获了,并且也是我们所抛出的异常,希望对大家有所帮助。
消化于:https://blog.csdn.net/MaybeUnforgiven/article/details/72989497