线程池非try catch异常处理

线程池非try catch异常处理

线程池非try catch异常处理:
Thread 类中有个接口 UncaughtExceptionHandler。通过实现这个接口,并调用 Thread.setUncaughtExceptionHandler(UncaughtExceptionHandler) 方法,我们就能为一个线程设置默认的异常处理机制,避免重复的 try…catch 了。

除此以外,我们还可以通过 Thread.setDefaultUncaughtExceptionHandler(UncaughtExceptionHandler) 设置全局的默认异常处理机制。此外,ThreadGroup 也实现了 UncaughtExceptionHandler 接口,所以通过 ThreadGroup 还可以为一组线程设置默认的异常处理机制。
可以重写 Thread 的UncaughtExceptionHandler 接口;
 @FunctionalInterface
    public interface UncaughtExceptionHandler {
        /**
         * Method invoked when the given thread terminates due to the
         * given uncaught exception.
         * <p>Any exception thrown by this method will be ignored by the
         * Java Virtual Machine.
         * @param t the thread
         * @param e the exception
         */
        void uncaughtException(Thread t, Throwable e);
    }
1.Thread 类实现默认的异常处理
public class ThreadException implements Thread.UncaughtExceptionHandler {

    @Override
    public void uncaughtException(Thread t, Throwable e) {
        System.out.println(“111111111111111111111111111111111”);
        System.out.println(e);
    }

 Thread thread=new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println(“this is run!!”);
                throw  new RuntimeException(“this is exception!!”);
            }
        });
 thread.setUncaughtExceptionHandler(new ThreadException());
 thread.start();
 异常信息会回调给ThreadException 类的uncaughtException方法;

2.配合线程池处理,线程池工作线程设置 UncaughtExceptionHandler
通过 ThreadFactory。通过 ThreadPoolExecutor 的构造函数和 Executors 中的工具方法,我们都可以为新创建的线程池设置 ThreadFactory。
ThreadFactory 是个接口,它只定义了一个方法 Thread newThread(Runnable r)。在这个方法中,我们可以为新创建出来的线程设置 UncaughtExceptionHandler。
也可以用 Apache Commons 和 Google Guava 这两个最有名的 Java 工具类库都为我们提供了相应的类库以简化配置 ThreadFactory 的工作。
下面以 Apache Commons 提供的 BasicThreadFactoryBuilder 为例
ThreadFactory executorThreadFactory = new BasicThreadFactory.Builder()
        .namingPattern(“task-scanner-executor-%d”)
        .uncaughtExceptionHandler(new LogUncaughtExceptionHandler(LOGGER))
        .build();
Executors.newSingleThreadExecutor(executorThreadFactory);
java 1.8 jdk 为例:配合线程池的ThreadFactory接口重写创建线程的方法,设置异常处理;
例如:
 ThreadFactory threadFactory= new ThreadFactory() {
            @Override
            public Thread newThread(Runnable r) {
                Thread thread=new Thread(r);
                thread.setUncaughtExceptionHandler(new ThreadException());
                return thread;
            }
        };
        ExecutorService executorService = Executors.newFixedThreadPool(1,threadFactory);
        Thread thread=new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println(“this is run!!”);
                throw  new RuntimeException(“this is exception!!”);
            }
        });

       executorService.execute(thread);
注意:       
executorService.submit(thread);无法打印出异常信息;只有调用 executorService.execute(thread); 方法打印了异常信息;
submit 方法是调用 execute 实现任务执行的。但是在调用 execute 之前,任务会被封装进 FutureTask 类中,然后最终工作线程执行的是 FutureTask 中的 run 方法。

FutureTask.run
try {
    result = c.call();
    ran = true;
} catch (Throwable ex) {
    result = null;
    ran = false;
    setException(ex);
}
 
protected void setException(Throwable t) {
    if (UNSAFE.compareAndSwapInt(this, stateOffset, NEW, COMPLETING)) {
        outcome = t;
        UNSAFE.putOrderedInt(this, stateOffset, EXCEPTIONAL); // final state
        finishCompletion();
    }
不同于直接调用 execute 方法,调用 submit 方法后,如果任务抛出异常,会被 setException 方法赋给代表执行结果的 outcome 变量,而不会继续抛出。因此,UncaughtExceptionHandler 也没有机会处理
如果想知道 submit 的执行结果是成功还是失败,必须调用 Future.get() 方法。
如果在执行 execute 方法时不在 Runnable.run 方法中写 try…catch 方法,自然异常会交由 UncaughtExceptionHandler 处理,但是,在这之前,线程的工作线程会因为异常而退出。虽然线程池会创建一个新的工作线程,但是如果这个步骤反复执行,效率自然会下降很多。    

ScheduledThreadPoolExecutor
ScheduledThreadPoolExecutor 是另一种常用的线程池,常用了执行延迟任务或定时任务。常用的方法为 scheduleXXX系列。那在这个线程池中异常是如何处理的呢?

其实,如果看过前面的部分,到这里也基本能猜出来了。ScheduledThreadPoolExecutor 用来封装任务的是 ScheduledFutureTask。ScheduledFutureTask 是 FutureTask 的子类,所以,异常也会被复制给 outcome。

但是,这里还是有一些差异的。在使用 ThreadPoolExecutor.submit 和 ScheduledThreadPoolExecutor.schedule 方法时,我们可以通过这两个方法返回的 Future 来获得执行结果,这包括正常结果,也包括异常结果。但是,对于 ScheduledThreadPoolExecutor.scheduleWithFixedDelay 和 scheduleAtFixedRate 这两个方法,其返回的 Future 只会用来取消任务,而不是得到结果。原因也很容易理解,因为这两个方法执行的是定时任务,是反复执行的。这也是为什么这两个方法的任务定义使用了 Runnable 接口,而不是有返回值的 Callable 接口。因此,对于这两个方法来说,在 Runnable.run 方法中加 try…catch 是必须的,否则很有可能出错了却毫不知情。

结论:
在 Thread 中,我们可以通过 UncaughtExceptionHandler 来实现默认的异常处理机制。但是在使用 ThreadPoolExecutor和 ScheduledThreadPoolExecutor 这两个 JDK 最主要的线程池时,使用 UncaughtExceptionHandler 是不合适的。所以,try…catch 往往是不可避免的,否则你的任务很有可能失败的悄无声息。

    

hmoban主题是根据ripro二开的主题,极致后台体验,无插件,集成会员系统
自学咖网 » 线程池非try catch异常处理