一起学并发编程 - 处理异常中止的线程

文章目录
  1. 1. 概述
  2. 2. 案例
    1. 2.1. 解决方案
  3. 3. - 说点什么

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

概述

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

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

案例

1.首先模拟一个连接池,提供

1
2
3
4
5
6
7
8
class ConnectionPool {
static void create() {
System.out.println("初始化连接池...");
}
static void close() {
System.out.println("关闭连接池...");
}
}

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

1
2
3
4
5
6
7
8
9
10
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

1
2
3
4
5
6
7
8
9
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中就有使用过,源码为:ZookeeperThreadZooKeeperCriticalThread,有兴趣可以去看看…

- 说点什么

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

  • 个人QQ:1837307557
  • battcn开源群(适合新手):391619659

微信公众号:battcn(欢迎调戏)