Java多線程-線程中止

不正確的線程中止-Stop

Stop:中止線程，并且清除監(jiān)控器鎖的信息，但是可能導致
線程安全問題，JDK不建議用。
Destroy: JDK未實現(xiàn)該方法。

/**
 * @author simon
 */
public class StopThread extends Thread {
    private int i = 0, 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);
    }
}

/**
 * @author simon
 * 示例3 - 線程stop強制性中止，破壞線程安全的示例
 */
public class Demo {
    public static void main(String[] args) throws InterruptedException {
        StopThread thread = new StopThread();
        thread.start();
        // 休眠1秒，確保i變量自增成功
        Thread.sleep(1000);
        // 暫停線程
        thread.stop(); // 錯誤的終止
        //thread.interrupt(); // @正確終止
        while (thread.isAlive()) {
            // 確保線程已經(jīng)終止
        } // 輸出結果
        thread.print();
    }
}

理想狀態(tài)：要么自增成功i=1, j=1，要么自增失敗i=0, j=0
真正程序執(zhí)行結果：i=1, j=0

cdn.xitu.io/2019/8/26/16cce951ce8a5145?w=798&h=120&f=png&s=17188">

沒有保證同步代碼塊里面數(shù)據(jù)的一致性，破壞了線程安全
stop方法直接停止線程

正確的線程中止-interrupt

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

如果目標線程是被I/O或者NIO中的Channel所阻塞，同樣，I/O操作會被中斷或者返回特殊異常值。達到終止線程的目的。

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

對Demo中的示例，stop()改成interrupt()后，最終輸出為"i=1 j=1"，數(shù)據(jù)一致。

正確的線程中止-標志位

/** 通過狀態(tài)位來判斷 */
public class Demo4 extends Thread {
  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秒之后，將狀態(tài)標志改為False，代表不繼續(xù)運行
    Thread.sleep(3000L);
    flag = false;
    System.out.println("程序運行結束");
  }
}

在上方代碼邏輯中，增加一個判斷，用來控制線程執(zhí)行的中止。