一块儿学并发编程 - 处理异常停止的线程

在单线程的开发过程当中，一般采用try-catch的方式进行异常捕获，可是这种方式在多线程环境中会显得无能为力，并且还有可能致使一些问题的出现，好比发生异常的时候不能及时回收系统资源，或者没法及时关闭当前的链接...

<!-- more -->

概述

Java中有两种异常，即已知异常（编辑器会提示捕获或者抛出）和未知异常（特殊状况下发生），因为线程中的run()方法是不接受抛出语句的（只能内部捕获），因此在面对未知异常的状况，线程默认的会将堆栈跟踪信息输出到控制台中（或者记录到错误日志文件中）而后退出程序。

在JDK1.5以前，不能为线程单独设置或指定一个默认的UncaughtExceptionHandler，为了设置UncaughtExceptionHandler，须要继承ThreadGroup并覆写uncaughtException方法。 幸运的是JDK1.5后线程提供了一个setUncaughtExceptionHandler方法，用来捕获并处理因线程中抛出的未知异常，以免程序终止。

案例

1.首先模拟一个链接池，提供

class ConnectionPool {
    static void create() {
        System.out.println("初始化链接池...");
    }
    static void close() {
        System.out.println("关闭链接池...");
    }
}

2.为了测试须要，只是简单模拟了一个异常

public static void main(String[] args) {
    ConnectionPool.create();
    try {
        //有个任务须要异步执行
        Thread thread = new Thread(() -> System.out.println(Integer.parseInt("ABC")), "T2");
        thread.start();
    } catch (Exception e) {
        ConnectionPool.close();
    }
}

分析： 从日志中，并未发现关闭资源应有的日志输出，很明显try-catch没有起做用，由于在main函数中他是主线程，当thread.start()以后，主线程的代码与子线程就没半毛钱关系了，因此发生在子线程内部的错误没法捕获到。

解决方案

使用UncaughtExceptionHandler，这里为了偷懒使用了lambda简化了匿名内部类的写法（也能够实现UncaughtExceptionHandler）

public static void main(String[] args) {
    ConnectionPool.create();
    Thread thread = new Thread(() -> System.out.println(Integer.parseInt("ABC")), "T1");
    thread.start();
    thread.setUncaughtExceptionHandler((t, e) -> {
        System.out.println("[线程] - [" + t.getName() + "] - [消息] - [" + e.getMessage() + "]");
        ConnectionPool.close();
    });
}

分析： 从日志中能够发现错误信息被咱们捕获了，而且能够成功释放资源！使用UncaughtExceptionHandler，能够捕获到未知异常且记录下自定义的日志（默认抛出堆栈信息），具体在Zookeeper中就有使用过，源码为：ZookeeperThread，ZooKeeperCriticalThread，有兴趣能够去看看...

- 说点什么

全文代码：https://gitee.com/battcn/battcn-concurent/tree/master/Chapter1-1/battcn-thread/src/main/java/com/battcn/chapter11

• 我的QQ：1837307557
• battcn开源群（适合新手）：391619659

微信公众号：battcn（欢迎调戏）