如何優雅地中止執行緒？
- 2020 年 3 月 27 日
- 筆記
本文來學習如何學習優雅地中止執行緒？通過 Java 執行緒的生老病死的學習，我相信大家對執行緒的運行以及執行緒的狀態有一定了解了，那麼我們現在來學習中止執行緒：
錯誤的執行緒中止 – stop
首先來講解一個錯誤的方式來中止執行緒 — stop：中止執行緒，並且清除監控器鎖的資訊，但是可能導致執行緒安全問題，JDK 不建議使用，類似的方法還有 destory，由於 JDK 從未實現該方法，在這裡就不介紹了。
接下來通過一段程式來講解為什麼 stop 會導致執行緒安全問題？
首先定義一個執行緒類 StopThread：
public class StopThread extends Thread { private int i = 0; private int j = 0; @Override public void run() { synchronized (this) { // 增加同步鎖，確保執行緒安全 ++i; try { // 休眠10秒,模擬耗時操作 Thread.sleep(10000); } catch (InterruptedException e) { e.printStackTrace(); } ++j; } } /** * 列印 i 和 j */ public void print() { System.out.println("i=" + i + " j=" + j); } } 這個執行緒做的事情就是在同步程式碼塊中對 i 和 j 這兩個變數進行自增操作，但是在這個執行過程中會進行 10 秒的睡眠，如果在這個過程中，如果用 stop 方法將執行緒中止的話，會導致 i 和 j 數據不正確，也可以說程式設計上的執行緒安全問題，因為主執行緒影響到了創建的 StopThread 執行緒的數據不正確性，理想的正確輸出結果應該是要麼全部添加成功，要麼都失敗，因為我們添加鎖的目的就是保證操作原子性或者說想讓這兩個變數在操作的時候不受其他執行緒干擾。
下面編寫 StopThreadDemo 類，來使用 stop 方法做個錯誤示範：
public class StopThreadDemo { public static void main(String[] args) throws InterruptedException { StopThread thread = new StopThread(); thread.start(); // 休眠 1 秒，確保 i 變數自增成功 Thread.sleep(1000); // 暫停執行緒 thread.stop(); // 錯誤的終止 while (thread.isAlive()) { // 確保執行緒已經終止 } // 輸出結果 thread.print(); } } 在 StopThreadDemo 類中，創建並啟動了 StopThread 執行緒，這個執行緒就是下執行變數 i 和 j 的自增操作，但是這個自增操作是用同步關鍵字包裹的同步程式碼塊，這樣做是為了讓兩個變數的自增操作實現原子性，不會受到其他執行緒的干擾，確保執行緒的安全。
但是在執行緒休眠的 10 秒內，通過 stop 方法把執行緒中止掉，會發現輸出結果為 i=1 j=0，也就是程式碼的前半段 i 自增實現，但是後半段 j 的自增失敗，會使執行緒中的數據出現不一致性，從而同步程式碼塊的保證的原子性的目標沒有達成，破壞了執行緒安全。
正確的執行緒中止 – interrupt
在介紹了錯誤的中止方式後，讓我們來學習正確的執行緒中止 – interrupt ：
如果目標執行緒在調用 Object class 的 wait() 、wait(long) 或 wait(long,int) 方法、join()、join(long,int) 或 sleep(long,int) 方法時阻塞，那麼 interrupt 會生效，該執行緒的中斷狀態將被清除，拋出 InterruptedException 異常。
如果目標執行緒是被 IO 或者 NIO 中的 Channel 所阻塞，同樣 IO 操作會被中斷返回特殊異常值，達到中止執行緒的目的。
如果以上條件都不滿足，則會設置此執行緒的中斷狀態。
接下來將 StopThreadDemo 中的 stop 改為 interrupt 來看下運行結果是什麼：
java.lang.InterruptedException: sleep interrupted at java.lang.Thread.sleep(Native Method) at com.wupx.thread.StopThread.run(StopThread.java:18) i=1 j=1 可以發現兩個變數的自增可以正常執行，保證了執行的數據一致性，interrupt 不會強制中止，將執行緒直接中斷，而是拋出異常通知我們，開發者就可以控制收到異常後的執行邏輯，讓整個程式處於執行緒安全的狀態，這是目前 JDK 版本中推薦的 interrupt 方法。
除了 interrupt 的正確方法外，還可以通過標誌位的形式來中止執行緒：
正確的執行緒中止 – 標誌位
如果程式碼程式邏輯中是循環執行的業務，可以在程式的執行中執行緒程式碼中增加一個標誌位，比如下面程式碼中在 while 循環中去執行這個程式，通過 flag 去控制程式是否繼續執行，如果在外部執行緒將 flag 修改為 false，那麼創建的子執行緒程式碼中會收到這個數據的變化，通過這個變數的形式，通知到另一個執行緒，從而達到控制執行緒中止的效果。
public class FlagThreadDemo { public volatile static boolean flag = true; public static void main(String[] args) throws InterruptedException { new Thread(() -> { try { while (flag) { // 判斷是否運行 System.out.println("運行中"); Thread.sleep(1000L); } } catch (InterruptedException e) { e.printStackTrace(); } }).start(); // 3 秒之後，將狀態標誌改為 false，代表不繼續運行 Thread.sleep(3000L); flag = false; System.out.println("程式運行結束"); } } 通過運行程式碼，得到的結果如下：
運行中 運行中 運行中 程式運行結束 這種方式受限於執行緒中所執行的業務邏輯，如果程式中是有可以用來做標誌位的條件的話可以用這種方式來做，也是一種正確的執行緒中止方式。
總結
本文主要講解了執行緒中止的三種方式：stop、interrupt 以及標誌位，大家學會了嗎，歡迎留言討論。
源程式碼可以在公眾號【武培軒】中回復【並發】獲取。
