[[320148]]

本文來學(xué)習(xí)如何學(xué)習(xí)優(yōu)雅地中止線程?通過 Java 線程的生老病死的學(xué)習(xí)，我相信大家對線程的運(yùn)行以及線程的狀態(tài)有一定了解了，那么我們現(xiàn)在來學(xué)習(xí)中止線程：

錯誤的線程中止 - stop

首先來講解一個錯誤的方式來中止線程 — stop：中止線程，并且清除監(jiān)控器鎖的信息，但是可能導(dǎo)致線程安全問題，JDK 不建議使用，類似的方法還有 destory，由于 JDK 從未實(shí)現(xiàn)該方法，在這里就不介紹了。

接下來通過一段程序來講解為什么 stop 會導(dǎo)致線程安全問題?

首先定義一個線程類 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 這兩個變量進(jìn)行自增操作，但是在這個執(zhí)行過程中會進(jìn)行 10 秒的睡眠，如果在這個過程中，如果用 stop 方法將線程中止的話，會導(dǎo)致 i 和 j 數(shù)據(jù)不正確，也可以說程序設(shè)計上的線程安全問題，因為主線程影響到了創(chuàng)建的 StopThread 線程的數(shù)據(jù)不正確性，理想的正確輸出結(jié)果應(yīng)該是要么全部添加成功，要么都失敗，因為我們添加鎖的目的就是保證操作原子性或者說想讓這兩個變量在操作的時候不受其他線程干擾。

下面編寫 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()) { 
            // 確保線程已經(jīng)終止 
        } // 輸出結(jié)果 
        thread.print(); 
    } 
} 

在 StopThreadDemo 類中，創(chuàng)建并啟動了 StopThread 線程，這個線程就是下執(zhí)行變量i 和 j 的自增操作，但是這個自增操作是用同步關(guān)鍵字包裹的同步代碼塊，這樣做是為了讓兩個變量的自增操作實(shí)現(xiàn)原子性，不會受到其他線程的干擾，確保線程的安全。

但是在線程休眠的 10 秒內(nèi)，通過 stop 方法把線程中止掉，會發(fā)現(xiàn)輸出結(jié)果為 i=1 j=0，也就是代碼的前半段 i 自增實(shí)現(xiàn)，但是后半段 j 的自增失敗，會使線程中的數(shù)據(jù)出現(xiàn)不一致性，從而同步代碼塊的保證的原子性的目標(biāo)沒有達(dá)成，破壞了線程安全。

正確的線程中止 - interrupt

在介紹了錯誤的中止方式后，讓我們來學(xué)習(xí)正確的線程中止 - interrupt ：

如果目標(biāo)線程在調(diào)用 Object class 的 wait() 、wait(long) 或 wait(long,int) 方法、join()、join(long,int) 或 sleep(long,int) 方法時阻塞，那么 interrupt 會生效，該線程的中斷狀態(tài)將被清除，拋出 InterruptedException 異常。

如果目標(biāo)線程是被 IO 或者 NIO 中的 Channel 所阻塞，同樣 IO 操作會被中斷返回特殊異常值，達(dá)到中止線程的目的。

如果以上條件都不滿足，則會設(shè)置此線程的中斷狀態(tài)。

接下來將 StopThreadDemo 中的 stop 改為 interrupt 來看下運(yùn)行結(jié)果是什么： 

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 

可以發(fā)現(xiàn)兩個變量的自增可以正常執(zhí)行，保證了執(zhí)行的數(shù)據(jù)一致性，interrupt 不會強(qiáng)制中止，將線程直接中斷，而是拋出異常通知我們，開發(fā)者就可以控制收到異常后的執(zhí)行邏輯，讓整個程序處于線程安全的狀態(tài)，這是目前 JDK 版本中推薦的 interrupt 方法。

除了 interrupt 的正確方法外，還可以通過標(biāo)志位的形式來中止線程：

正確的線程中止 - 標(biāo)志位如果代碼程序邏輯中是循環(huán)執(zhí)行的業(yè)務(wù)，可以在程序的執(zhí)行中線程代碼中增加一個標(biāo)志位，比如下面代碼中在 while 循環(huán)中去執(zhí)行這個程序，通過 flag 去控制程序是否繼續(xù)執(zhí)行，如果在外部線程將 flag 修改為 false，那么創(chuàng)建的子線程代碼中會收到這個數(shù)據(jù)的變化，通過這個變量的形式，通知到另一個線程，從而達(dá)到控制線程中止的效果。 

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 

通過運(yùn)行代碼，得到的結(jié)果如下： 

運(yùn)行中 
運(yùn)行中 
運(yùn)行中 
程序運(yùn)行結(jié)束 

這種方式受限于線程中所執(zhí)行的業(yè)務(wù)邏輯，如果程序中是有可以用來做標(biāo)志位的條件的話可以用這種方式來做，也是一種正確的線程中止方式。

總結(jié)

本文主要學(xué)習(xí)了線程中止的三種方式：stop、interrupt 以及標(biāo)志位，大家學(xué)會了嗎，歡迎留言討論。