在Java程序中，我們想要停止一個線程可以通過interrupt方法進行停止。但是當(dāng)我們調(diào)用interrupt方法之后，它可能并不會立刻就會停止線程，而是通知線程需要停止。線程接收到通知之后會根據(jù)自身的情況判斷是否需要停止，它可能會立即停止，也有可能會執(zhí)行一段時間后停止，也可能根本就不停止。

那么Java為什么要選擇這種非強制性的線程中斷呢？其實更多是為了數(shù)據(jù)安全，保證程序的健壯性。因為我們不知道程序正在做什么事情。如果貿(mào)然停止，可能會造成數(shù)據(jù)的錯亂、不完整。

一個簡單的例子：

public class _24_ThreadTest implements Runnable {
    @Override
    public void run() {
        int count = 0;
        while (!Thread.currentThread().isInterrupted() &amp;&amp; count &lt;= 2000) {
            System.out.println("count: " + count++);
        }
    }
    public static void main(String[] args) throws Exception {
        _24_ThreadTest threadTest = new _24_ThreadTest();
        Thread thread = new Thread(threadTest);
        thread.start();
        Thread.sleep(10);
        // 中斷線程
        thread.interrupt();
    }
}

這個例子是一個簡單的通過interrupt中斷線程的案例，run方法中通過判斷當(dāng)前線程是否中斷，并且count是否大于2000來進行循環(huán)。如果線程中斷則退出循環(huán)，線程執(zhí)行結(jié)束。這種就屬于線程正常停止的情況。

Sleep是否會收到線程中斷信號

public class _24_ThreadTest implements Runnable {
    @Override
    public void run() {
        int count = 0;
        while (!Thread.currentThread().isInterrupted() &amp;&amp; count &lt;= 2000) {
            try {
                System.out.println("count: " + count++);
                // 子線程睡眠
                Thread.sleep(1000 * 2);
                System.out.println("方法體：" + Thread.currentThread().isInterrupted());
            } catch (InterruptedException e) {
                System.out.println("異常：" + Thread.currentThread().isInterrupted());
                // 線程中斷標志位被重置為false
                e.printStackTrace();
            }
        }
    }
    public static void main(String[] args) throws Exception {
        _24_ThreadTest threadTest = new _24_ThreadTest();
        Thread thread = new Thread(threadTest);
        thread.start();
        Thread.sleep(10);
        // 中斷線程
        thread.interrupt();
    }
}

如果在子線程中睡眠中，主線程通過interrupt方法進行中斷，那么子線程還能不能收到中斷信號。其實在這種情況下線程也是可以接收到信號通知的，這個時候會拋出InterruptedException，并且將線程中斷標志位設(shè)置為false。

在拋出異常后，線程標志位被設(shè)置為false，那么在下次循環(huán)判斷count沒有為false的情況下，還是可以進入循環(huán)體的。這個時候線程就無法停止。

執(zhí)行結(jié)果：

案例場景：

在進行一些后臺任務(wù)通過線程跑的時候，如果在循環(huán)中遇到線程中斷異常，我們需要終止當(dāng)前任務(wù)，并且告訴客戶端當(dāng)前任務(wù)執(zhí)行失敗的是哪條記錄，這種情況下就可以通過異常中再次中斷的方式來停止線程，并且可以返回給客戶端當(dāng)前出現(xiàn)異常的記錄是哪條。而不會是接著執(zhí)行下去。

解決方法

public class _24_ThreadTest implements Runnable {
    @Override
    public void run() {
        int count = 0;
        while (!Thread.currentThread().isInterrupted() && count <= 2000) {
            try {
                System.out.println("count: " + count++);
                // 子線程睡眠
                Thread.sleep(1000 * 2);
                Thread.currentThread().interrupt();
                System.out.println("方法體：" + Thread.currentThread().isInterrupted());
            } catch (InterruptedException e) {
                // 再次中斷
                Thread.currentThread().interrupt();
                System.out.println("異常：" + Thread.currentThread().isInterrupted());
                e.printStackTrace();
            }
        }
    }
    public static void main(String[] args) throws Exception {
        _24_ThreadTest threadTest = new _24_ThreadTest();
        Thread thread = new Thread(threadTest);
        thread.start();
        Thread.sleep(10);
        // 中斷線程
        thread.interrupt();
    }
}

既然我們已經(jīng)知道，在出現(xiàn)線程中斷異常之后線程中斷標志位會被重置為false，那么我們可以在異常中手動的再次中斷當(dāng)前線程，那么就可以完全停止線程任務(wù)。