如何優(yōu)雅地中止線程勃教?

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

錯誤的線程中止 - stop

首先來講解一個錯誤的方式來中止線程 — stop:中止線程污抬,并且清除監(jiān)控器鎖的信息,但是可能導(dǎo)致線程安全問題绳军,JDK 不建議使用印机,類似的方法還有 destory矢腻,由于 JDK 從未實現(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);
    }
}

這個線程做的事情就是在同步代碼塊中對 ij 這兩個變量進(jìn)行自增操作咒劲,但是在這個執(zhí)行過程中會進(jìn)行 10 秒的睡眠顷蟆,如果在這個過程中,如果用 stop 方法將線程中止的話腐魂,會導(dǎo)致 ij 數(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í)行變量 ij 的自增操作,但是這個自增操作是用同步關(guān)鍵字包裹的同步代碼塊豪嗽,這樣做是為了讓兩個變量的自增操作實現(xiàn)原子性谴蔑,不會受到其他線程的干擾,確保線程的安全龟梦。

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

正確的線程中止 - interrupt

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

如果目標(biāo)線程在調(diào)用 Object classwait() 挣输、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 來看下運行結(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á)到控制線程中止的效果货徙。

public class FlagThreadDemo {
    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)標(biāo)志改為 false,代表不繼續(xù)運行
        Thread.sleep(3000L);
        flag = false;
        System.out.println("程序運行結(jié)束");
    }
}

通過運行代碼痴颊,得到的結(jié)果如下:

運行中
運行中
運行中
程序運行結(jié)束

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

總結(jié)

本文主要講解了線程中止的三種方式:stop锌杀、interrupt 以及標(biāo)志位,大家學(xué)會了嗎泻仙,歡迎留言討論糕再。

源代碼可以在公眾號【武培軒】中回復(fù)【并發(fā)】獲取。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末玉转,一起剝皮案震驚了整個濱河市突想,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌,老刑警劉巖猾担,帶你破解...
    沈念sama閱讀 218,284評論 6 506
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件袭灯,死亡現(xiàn)場離奇詭異,居然都是意外死亡绑嘹,警方通過查閱死者的電腦和手機(jī)稽荧,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,115評論 3 395
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來工腋,“玉大人姨丈,你說我怎么就攤上這事∩醚” “怎么了构挤?”我有些...
    開封第一講書人閱讀 164,614評論 0 354
  • 文/不壞的土叔 我叫張陵,是天一觀的道長惕鼓。 經(jīng)常有香客問我筋现,道長,這世上最難降的妖魔是什么箱歧? 我笑而不...
    開封第一講書人閱讀 58,671評論 1 293
  • 正文 為了忘掉前任矾飞,我火速辦了婚禮,結(jié)果婚禮上呀邢,老公的妹妹穿的比我還像新娘洒沦。我一直安慰自己,他們只是感情好价淌,可當(dāng)我...
    茶點故事閱讀 67,699評論 6 392
  • 文/花漫 我一把揭開白布申眼。 她就那樣靜靜地躺著,像睡著了一般蝉衣。 火紅的嫁衣襯著肌膚如雪括尸。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 51,562評論 1 305
  • 那天病毡,我揣著相機(jī)與錄音濒翻,去河邊找鬼。 笑死啦膜,一個胖子當(dāng)著我的面吹牛有送,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播僧家,決...
    沈念sama閱讀 40,309評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼雀摘,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 39,223評論 0 276
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎膜赃,沒想到半個月后豌注,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體伤塌,經(jīng)...
    沈念sama閱讀 45,668評論 1 314
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,859評論 3 336
  • 正文 我和宋清朗相戀三年轧铁,在試婚紗的時候發(fā)現(xiàn)自己被綠了每聪。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 39,981評論 1 348
  • 序言:一個原本活蹦亂跳的男人離奇死亡齿风,死狀恐怖药薯,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情救斑,我是刑警寧澤童本,帶...
    沈念sama閱讀 35,705評論 5 347
  • 正文 年R本政府宣布,位于F島的核電站脸候,受9級特大地震影響穷娱,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜运沦,卻給世界環(huán)境...
    茶點故事閱讀 41,310評論 3 330
  • 文/蒙蒙 一泵额、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧携添,春花似錦嫁盲、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,904評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至左敌,卻和暖如春瘾蛋,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背母谎。 一陣腳步聲響...
    開封第一講書人閱讀 33,023評論 1 270
  • 我被黑心中介騙來泰國打工瘦黑, 沒想到剛下飛機(jī)就差點兒被人妖公主榨干…… 1. 我叫王不留京革,地道東北人奇唤。 一個月前我還...
    沈念sama閱讀 48,146評論 3 370
  • 正文 我出身青樓,卻偏偏與公主長得像匹摇,于是被迫代替她去往敵國和親咬扇。 傳聞我的和親對象是個殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點故事閱讀 44,933評論 2 355

推薦閱讀更多精彩內(nèi)容