成人免费xxxxx在线视频软件_久久精品久久久_亚洲国产精品久久久_天天色天天色_亚洲人成一区_欧美一级欧美三级在线观看

聊一下ShutdownHook原理

開發(fā) 后端
在java中我們可以寫出如下代碼來捕獲kill信號,只需要實現SignalHandler接口以及handle方法,程序入口處注冊要監(jiān)聽的信號即可,當然不是每個信號都能捕獲處理。

[[394735]]

ShutdownHook介紹

在java程序中,很容易在進程結束時添加一個鉤子,即ShutdownHook。通常在程序啟動時加入以下代碼即可

  1. Runtime.getRuntime().addShutdownHook(new Thread(){ 
  2.     @Override 
  3.     public void run() { 
  4.         System.out.println("I'm shutdown hook..."); 
  5.     } 
  6. }); 

有了ShutdownHook我們可以

  • 在進程結束時做一些善后工作,例如釋放占用的資源,保存程序狀態(tài)等
  • 為優(yōu)雅(平滑)發(fā)布提供手段,在程序關閉前摘除流量

不少java中間件或框架都使用了ShutdownHook的能力,如dubbo、spring等。

spring在application context被load時會注冊一個ShutdownHook。這個ShutdownHook會在進程退出前執(zhí)行銷毀bean,發(fā)出ContextClosedEvent等動作。而dubbo在spring框架下正是監(jiān)聽了ContextClosedEvent,調用dubboBootstrap.stop()來實現清理現場和dubbo的優(yōu)雅發(fā)布,spring的事件機制默認是同步的,所以能在publish事件時等待所有監(jiān)聽者執(zhí)行完畢。

ShutdownHook原理

ShutdownHook的數據結構與執(zhí)行順序

  • 當我們添加一個ShutdownHook時,會調用ApplicationShutdownHooks.add(hook),往ApplicationShutdownHooks類下的靜態(tài)變量private static IdentityHashMap
  • ApplicationShutdownHooks類初始化時會把hooks添加到Shutdown的hooks中去,而Shutdown的hooks是系統(tǒng)級的ShutdownHook,并且系統(tǒng)級的ShutdownHook由一個數組構成,只能添加10個
  • 系統(tǒng)級的ShutdownHook調用了thread類的run方法,所以系統(tǒng)級的ShutdownHook是同步有序執(zhí)行的
  1. private static void runHooks() { 
  2.     for (int i=0; i < MAX_SYSTEM_HOOKS; i++) { 
  3.         try { 
  4.             Runnable hook; 
  5.             synchronized (lock) { 
  6.                 // acquire the lock to make sure the hook registered during 
  7.                 // shutdown is visible here. 
  8.                 currentRunningHook = i; 
  9.                 hook = hooks[i]; 
  10.             } 
  11.             if (hook != null) hook.run(); 
  12.         } catch(Throwable t) { 
  13.             if (t instanceof ThreadDeath) { 
  14.                 ThreadDeath td = (ThreadDeath)t; 
  15.                 throw td; 
  16.             } 
  17.         } 
  18.     } 
  • 系統(tǒng)級的ShutdownHook的add方法是包可見,即我們不能直接調用它
  • ApplicationShutdownHooks位于下標1處,且應用級的hooks,執(zhí)行時調用的是thread類的start方法,所以應用級的ShutdownHook是異步執(zhí)行的,但會等所有hook執(zhí)行完畢才會退出。
  1. static void runHooks() { 
  2.     Collection<Thread> threads; 
  3.     synchronized(ApplicationShutdownHooks.class) { 
  4.         threads = hooks.keySet(); 
  5.         hooks = null
  6.     } 
  7.  
  8.     for (Thread hook : threads) { 
  9.         hook.start(); 
  10.     } 
  11.     for (Thread hook : threads) { 
  12.         while (true) { 
  13.             try { 
  14.                 hook.join(); 
  15.                 break; 
  16.             } catch (InterruptedException ignored) { 
  17.             } 
  18.         } 
  19.     } 

用一副圖總結如下:

ShutdownHook觸發(fā)點

從Shutdown的runHooks順藤摸瓜,我們得出以下兩個調用路徑

重點看Shutdown.exit 和 Shutdown.shutdown

Shutdown.exit

跟進Shutdown.exit的調用方,發(fā)現有 Runtime.exit 和 Terminator.setup

  • Runtime.exit 是代碼中主動結束進程的接口
  • Terminator.setup 被 initializeSystemClass 調用,當第一個線程被初始化的時候被觸發(fā),觸發(fā)后注冊一個信號監(jiān)聽函數,捕獲kill發(fā)出的信號,調用Shutdown.exit結束進程

這樣覆蓋了代碼中主動結束進程和被kill殺死進程的場景。

主動結束進程不必介紹,這里說一下信號捕獲。在java中我們可以寫出如下代碼來捕獲kill信號,只需要實現SignalHandler接口以及handle方法,程序入口處注冊要監(jiān)聽的信號即可,當然不是每個信號都能捕獲處理。

  1. public class SignalHandlerTest implements SignalHandler { 
  2.  
  3.     public static void main(String[] args) { 
  4.  
  5.         Runtime.getRuntime().addShutdownHook(new Thread() { 
  6.             @Override 
  7.             public void run() { 
  8.                 System.out.println("I'm shutdown hook "); 
  9.             } 
  10.         }); 
  11.  
  12.         SignalHandler sh = new SignalHandlerTest(); 
  13.         Signal.handle(new Signal("HUP"), sh); 
  14.         Signal.handle(new Signal("INT"), sh); 
  15.         //Signal.handle(new Signal("QUIT"), sh);// 該信號不能捕獲 
  16.         Signal.handle(new Signal("ABRT"), sh); 
  17.         //Signal.handle(new Signal("KILL"), sh);// 該信號不能捕獲 
  18.         Signal.handle(new Signal("ALRM"), sh); 
  19.         Signal.handle(new Signal("TERM"), sh); 
  20.  
  21.         while (true) { 
  22.             System.out.println("main running"); 
  23.             try { 
  24.                 Thread.sleep(2000L); 
  25.             } catch (InterruptedException e) { 
  26.                 e.printStackTrace(); 
  27.             } 
  28.         } 
  29.     } 
  30.  
  31.     @Override 
  32.     public void handle(Signal signal) { 
  33.         System.out.println("receive signal " + signal.getName() + "-" + signal.getNumber()); 
  34.         System.exit(0); 
  35.     } 

要注意的是,通常來說我們捕獲信號,做了一些個性化的處理后需要主動調用System.exit,否則進程就不會退出了,這時只能使用kill -9來強制殺死進程了。

而且每次信號的捕獲是在不同的線程中,所以他們之間的執(zhí)行是異步的。

Shutdown.shutdown

這個方法可以看注釋

  1. /* Invoked by the JNI DestroyJavaVM procedure when the last non-daemon 
  2.   * thread has finished.  Unlike the exit method, this method does not 
  3.   * actually halt the VM. 
  4.   */ 

翻譯一下就是該方法會在最后一個非daemon線程(非守護線程)結束時被JNI的DestroyJavaVM方法調用。

java中有兩類線程,用戶線程和守護線程,守護線程是服務于用戶線程,如GC線程,JVM判斷是否結束的標志就是是否還有用戶線程在工作。當最后一個用戶線程結束時,就會調用 Shutdown.shutdown。這是JVM這類虛擬機語言特有的"權利",倘若是golang這類編譯成可執(zhí)行的二進制文件時,當全部用戶線程結束時是不會執(zhí)行ShutdownHook的。

舉個例子,當java進程正常退出時,沒有在代碼中主動結束進程,也沒有kill,就像這樣

  1. public static void main(String[] args) { 
  2.  
  3.     Runtime.getRuntime().addShutdownHook(new Thread() { 
  4.         @Override 
  5.         public void run() { 
  6.             System.out.println("I'm shutdown hook "); 
  7.         } 
  8.     }); 

當main線程運行完了后,也能打印出I'm shutdown hook,反觀golang就做不到這一點

通過如上兩個調用的分析,我們概括出如下結論:

我們能看出java的ShutdownHook其實覆蓋的非常全面了,只有一處無法覆蓋,即當我們殺死進程時使用了kill -9時,由于程序無法捕獲處理,進程被直接殺死,所以無法執(zhí)行ShutdownHook。

總結

綜上,我們得出一些結論

  • 重寫捕獲信號需要注意主動退出進程,否則進程可能永遠不會退出,捕獲信號的執(zhí)行是異步的
  • 用戶級的ShutdownHook是綁定在系統(tǒng)級的ShutdownHook之上,且用戶級是異步執(zhí)行,系統(tǒng)級是同步順序執(zhí)行,用戶級處于系統(tǒng)級執(zhí)行順序的第二位
  • ShutdownHook 覆蓋的面比較廣,不論是手動調用接口退出進程,還是捕獲信號退出進程,抑或是用戶線程執(zhí)行完畢退出,都會執(zhí)行ShutdownHook,唯一不會執(zhí)行的就是kill -9

 

責任編輯:武曉燕 來源: 捉蟲大師
相關推薦

2025-01-10 11:07:28

2021-04-27 07:52:18

SQLNULLOR

2021-06-30 00:19:43

AOP動態(tài)代理

2022-02-08 08:31:52

const關鍵字C語言

2021-04-21 21:06:11

數據結構

2021-03-10 00:02:01

Redis

2021-05-31 06:28:35

AutoMapper對象映射器

2021-03-26 00:20:34

NFT區(qū)塊鏈數據庫

2021-08-07 07:56:59

Node邏輯對象

2019-01-31 07:16:06

2020-01-17 09:07:14

分布式系統(tǒng)網絡

2021-06-06 12:59:14

實現方式計數

2023-02-07 06:42:24

Pulsar負載均衡

2020-09-29 09:41:50

Spring Boot項目代碼

2024-04-26 08:41:04

ViteHMR項目

2023-02-09 08:48:47

Java虛擬機

2024-09-12 10:06:21

2021-01-26 05:06:24

LinuxXargs 命令

2015-06-16 13:04:35

C#開發(fā)者JAVA 開發(fā)者

2024-05-29 11:24:27

點贊
收藏

51CTO技術棧公眾號

主站蜘蛛池模板: 羞羞网站在线观看 | 91精品入口蜜桃 | 成人精品视频在线 | 日韩视频在线观看中文字幕 | av手机在线播放 | аⅴ资源新版在线天堂 | 色综合色综合网色综合 | 久久精品福利 | 欧美国产精品一区二区三区 | 亚洲不卡在线观看 | 久久国产精品99久久久久久丝袜 | 欧美在线综合 | 成人免费视频网站在线看 | 一道本不卡视频 | 欧美日韩国产免费 | 一级电影免费看 | 有码一区 | 欧美日高清视频 | h视频在线播放 | 国产女人与拘做受视频 | 久草新在线 | 在线观看日韩精品视频 | 亚洲天堂一区二区 | 国产精品999 | 国产欧美三区 | 一区二区三区在线免费看 | 夜夜夜久久久 | 国产午夜精品一区二区三区四区 | 午夜精品久久久久久久久久久久 | 国产一区免费视频 | 中文字幕亚洲视频 | 在线精品一区 | 亚洲国产成人精 | 成人影院网站ww555久久精品 | 国产欧美日韩一区 | 欧美中文字幕在线观看 | 在线观看免费高清av | 一区二区三区视频在线 | 国产一二三区电影 | 日韩欧美在 | 欧美国产中文字幕 |