java并发--捕获线程异常

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;

public class ExceptionDemo  {
    class myRunnalbe implements Runnable{

        @Override
        public void run() {
            System.out.println("thread:" + Thread.currentThread());
            throw new RuntimeException();// 抛出一个异常
        }
        
    }
    
    class myUncaughtExcuptionHandler implements Thread.UncaughtExceptionHandler {
        /**
         * 处理异常
         */
        @Override
        public void uncaughtException(Thread t, Throwable e) {
            System.out.println("Exception::" + e);
        }
    }
    /**
     * 线程工厂
     * @author Administrator
     *
     */
    class myThreadFactory implements ThreadFactory {

        @Override
        public Thread newThread(Runnable r) {
            Thread t = new Thread(r);
            t.setUncaughtExceptionHandler(new myUncaughtExcuptionHandler());// 设置一个异常处理器
            System.out.println("eh::" + t.getUncaughtExceptionHandler());
            return t;
        }
    }
    
    public static void main(String[] args) {
        ExceptionDemo demo = new ExceptionDemo();
        ExecutorService executor = Executors.newCachedThreadPool(demo.new myThreadFactory());
        executor.execute(demo.new myRunnalbe());
    }
}