线程一1.0线程获取线程的运行时异常，Hook线程

下图&＃xff1a;

线程在执行单元中是不允许抛出checked异常的&＃xff0c;&＃xff0c;而且线程运行在自己的上下文中&＃xff0c;派生他的线程将无法直接获得它运行中出现的异常信息&＃xff0c;对此Java给我们提供了一个uncaughtexceptionHandler接口&＃xff0c;当线程在运行过程中出现异常时&＃xff0c;就会回调UncaughtExceptionHandler接口&＃xff0c;从而得知那个线程在运行中出错&＃xff0c;以及出现了什么样的错误&＃xff0c;如下

public static void main(String[] args) {
        try{
            Thread t &＃61;new Thread(new Runnable(){
                &＃64;Override
                public void run() {
                    int i &＃61; 10/0;
                    System.out.println("run....");
                }
            });
            t.setUncaughtExceptionHandler(new UncaughtExceptionHandler() {
                &＃64;Override
                public void uncaughtException(Thread t,   Throwable e) {
                    System.out.println("catch 到了"&＃43;t.getName());
                    e.printStackTrace();
                }
            });
            t.start();
        }catch(Exception e){
            System.out.println("catch 不到");
        }
    }

结果如下&＃xff1a;

public static void main(String[] args) {
        try{
            Thread t &＃61;new Thread(new Runnable(){
                &＃64;Override
                public void run() {
                    int i &＃61; 10/0;
                    System.out.println("run....");
                }
            });
            t.start();
        }catch(Exception e){
            System.out.println("catch 不到");
        }
    }

二》 uncaughtExceptionHandker 源码分析

在没有向线程注入uncaughtExceptionHandler回调接口的时候线程若是出现了异常该怎么办&＃xff1f;

get方法首先会判断当前线程中是否设置了handler&＃xff0c;有则执行线程自己的uncaughtException 方法&＃xff0c;否则就到 所在的threadgroup中获取&＃xff0c;threadgroup同样也实现了uncaugthExceptionHandler接口&＃xff0c;看看threadgroup里面的uncaught-Exception&＃xff1a;

该threadgroup如果有父threadgroup&＃xff0c;则直接调用父group的uncaughtException&＃xff0c;

如果设置了全局默认的uncaughtexceptionHandler,则调用uncaughtException方法&＃xff0c;

若既没有父threadgroup&＃xff0c;也没有设置全局的默认uncaughtException&＃xff0c;则会直接将异常的堆栈信息定向到system&＃xff0c;err中

public static void main(String[] args) {
        ThreadGroup maingroup&＃61;Thread.currentThread().getThreadGroup();
        System.out.println(maingroup.getName());
        System.out.println(maingroup.getParent());
        System.out.println(maingroup.getParent().getParent());
        final Thread thread&＃61;new Thread(()->{
            try {
                TimeUnit.SECONDS.sleep(2);
            } catch (Exception e) {
                // TODO: handle exception
            }
        
            System.out.println(1/0);
        },"test-thread");
        thread.start();
    }

上面代码没有设置默认的handler&＃xff0c;也没有对thread指定handler&＃xff0c;因此当thread出现异常的时候&＃xff0c;会向上寻找group的uncaughtException,如图&＃xff1a;

三  注入钩子线程&＃xff1a;

hook线程&＃xff1a;

jvm的退出是由于jvm进程中没有活跃的非守护线程&＃xff0c;或者收到了系统的中断信号&＃xff0c;向jvm程序中注入了一个Hook线程&＃xff0c;在jvm进城退出的时候&＃xff0c;Hook线程会启动执行&＃xff0c;通过Runtime可以为jvm注入多个Hook线程&＃xff0c;例子&＃xff1a;

public static void main(String[] args) {
     Runtime.getRuntime().addShutdownHook(new Thread() {
         &＃64;Override
        public void run() {
             try {
                 System.out.println("the hook thread 1 is running.");
                TimeUnit.SECONDS.sleep(1);
            } catch (Exception e) {
                e.printStackTrace();
                
            }
             System.out.println("the hook thread 1 will exit.");
        }
     });
     //可以注入多个
     Runtime.getRuntime().addShutdownHook(new Thread() {
         &＃64;Override
        public void run() {
             try {
                 System.out.println("the hook thread 2 is running.");
                TimeUnit.SECONDS.sleep(1);
            } catch (Exception e) {
                e.printStackTrace();
                
            }
             System.out.println("the hook thread 2 will exit.");
        }
     });
    } 

java 注入了两个Hook线程&＃xff0c;在main线程中结束&＃xff0c;也就是jvm中没有了活动的非守护线程&＃xff0c;jvm即将推出的时候&＃xff0c;两个Hook线程会被启动并且运行&＃xff0c;结果如下&＃xff1a;

在我们开发中经常会遇到Hook线程&＃xff0c;比如为了防止某个程序被重复启动&＃xff0c;在进程启动时会创建一个lock文件&＃xff0c;进程收到中断信号的时候会删除这个lock文件的存在&＃xff0c; 模拟一个利用Hook线程防止重复启动的程序&＃xff0c;;

public class ThreadGroupCreator {
    private final static String LOCK_PATH&＃61;"/wenjian/home";
    private final static String LOCK_FILE&＃61;".lock";
    private final static String PERMISSIONS&＃61;"rw-------";
    public static void main(String[] args) throws IOException{
    Runtime.getRuntime().addShutdownHook(new Thread(()->{
        System.out.println("the program received kill signal.");
        getLockFile().toFile().delete();
        
    }));
        checkckRunning();
        for(; ;) {
            try {
                TimeUnit.MILLISECONDS.sleep(1);
                System.out.println("program is running.");
            } catch (Exception e) {
                e.printStackTrace();
                
            }
        }
    }
    private static void checkckRunning() throws IOException {
        Path path&＃61;getLockFile();
        if (path.toFile().exists()) {
            throw new RuntimeException("the program already running.");
        }
        Setperms&＃61;PosixFilePermissions.fromString(PERMISSIONS);
        Files.createFile(path, PosixFilePermissions.asFileAttribute(perms));
    }
    private static Path getLockFile() {
        return java.nio.file.Paths.get(LOCK_PATH, LOCK_FILE);
    }
}

运行发现多了个.lock文件

执行kill pid jvm收到中断信号&＃xff0c;并且启动Hook线程&＃xff0c;删除。,lock 文件 输出如下

Hook线程只会在收到退出信号的时候会被执行&＃xff0c;如果在kill的时候使用了参数-9&＃xff0c;那么Hook线程不会得到执行&＃xff0c;进程会立即退出&＃xff0c;因此。lock文件得不到清理

Hook线程中也可以执行一些资源释放的工作&＃xff0c;比如关闭文件句柄&＃xff0c;socket 连接。数据库的connection等

尽量不要再Hook线程中执行一些非常耗时非常浪费时间的操作&＃xff0c;会导致程序迟迟不能退出