java中斷線程的正確姿勢(shì)完整示例

更新時(shí)間：2023年05月10日 11:24:48 作者：一個(gè)程序員的成長(zhǎng)

這篇文章主要為大家介紹了java中斷線程的正確姿勢(shì)完整示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

Java停止線程的邏輯（協(xié)同、通知）

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

那么Java為什么要選擇這種非強(qiáng)制性的線程中斷呢？其實(shí)更多是為了數(shù)據(jù)安全，保證程序的健壯性。因?yàn)槲覀儾恢莱绦蛘谧鍪裁词虑?。如果貿(mào)然停止，可能會(huì)造成數(shù)據(jù)的錯(cuò)亂、不完整。

一個(gè)簡(jiǎn)單的例子：

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();
    }
}

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

Sleep是否會(huì)收到線程中斷信號(hào)

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());
                // 線程中斷標(biāo)志位被重置為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方法進(jìn)行中斷，那么子線程還能不能收到中斷信號(hào)。其實(shí)在這種情況下線程也是可以接收到信號(hào)通知的，這個(gè)時(shí)候會(huì)拋出InterruptedException，并且將線程中斷標(biāo)志位設(shè)置為false。

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

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

案例場(chǎng)景：

在進(jìn)行一些后臺(tái)任務(wù)通過線程跑的時(shí)候，如果在循環(huán)中遇到線程中斷異常，我們需要終止當(dāng)前任務(wù)，并且告訴客戶端當(dāng)前任務(wù)執(zhí)行失敗的是哪條記錄，這種情況下就可以通過異常中再次中斷的方式來停止線程，并且可以返回給客戶端當(dāng)前出現(xiàn)異常的記錄是哪條。而不會(huì)是接著執(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)線程中斷異常之后線程中斷標(biāo)志位會(huì)被重置為false，那么我們可以在異常中手動(dòng)的再次中斷當(dāng)前線程，那么就可以完全停止線程任務(wù)。