java 兩階段終止線程的正確做法

更新時(shí)間：2021年12月12日 11:49:44 作者：bkpp976

這篇文章主要給大家分享了java 兩階段終止線程的正確做法，文章列舉出錯(cuò)誤的做法與正確做法做對(duì)比，具有一定的參考價(jià)值，需要的小伙伴可以參考一下，希望對(duì)你有所幫助

一、怎么優(yōu)雅地關(guān)閉一個(gè)線程？

在一個(gè)線程T1中如何優(yōu)雅地關(guān)閉線程T2(也就是說要給T2一個(gè)機(jī)會(huì)釋放持有的資源）?

1.錯(cuò)誤做法

使用stop()方法停止線程：

stop()方法會(huì)真正殺死線程，如果此時(shí)該線程持有鎖，那么其他線程將永遠(yuǎn)無法獲取鎖。

使用System.exit()方法停止線程：

會(huì)讓整個(gè)進(jìn)程都退出

2.正確做法

思路：

代碼實(shí)現(xiàn)：

public class Test {
    public static void main(String[] args) throws InterruptedException {
        TwoPhaseTermination twoPhaseTermination = new TwoPhaseTermination();
        twoPhaseTermination.start();

        Thread.sleep(3000);
        twoPhaseTermination.stop();

    }
}

class TwoPhaseTermination{
    // 監(jiān)控線程
    private Thread monitorThread;

    public void start(){
        monitorThread = new Thread(()->{
            Thread current = Thread.currentThread();
            while(true){
                if(current.isInterrupted()){

                    System.out.println("線程要關(guān)閉了...");
                    break;
                }
                try {
                    Thread.sleep(1000); // 階段1
                    System.out.println("監(jiān)控線程正在工作...."); // 階段2
                     // 如果在階段2被打斷，線程的isInterrupted標(biāo)志位為true,會(huì)捕抓到信號(hào)并關(guān)閉線程
                     // 如果在階段1被打斷，會(huì)進(jìn)入catch語(yǔ)句塊，并且isInterrupted標(biāo)志位清空，無法關(guān)閉線程
                } catch (InterruptedException e) {
                    e.printStackTrace();
                    // 需要重新設(shè)置isInterrupted標(biāo)志位為true
                    monitorThread.interrupt();
                }
            }

        });
        // 啟動(dòng)線程
        monitorThread.start();
    }

    public void stop(){
        // 設(shè)置isInterrupted標(biāo)志位true
        monitorThread.interrupt();
    }
}

運(yùn)行結(jié)果：

兩階段關(guān)閉線程：

二、要點(diǎn)

為什么需要在catch代碼塊中重新執(zhí)行monitorThread.interrupt()?因?yàn)?code>Thread.sleep()執(zhí)行過程中被打斷，isInterrupted標(biāo)志位會(huì)清空，下一次進(jìn)入while循環(huán)就會(huì)忽略這次打斷，繼續(xù)運(yùn)行線程。

演示一下把monitorThread.interrupt()注釋掉的結(jié)果: