結(jié)束線程

  • 線程對(duì)象屬于一次性消耗品,一般線程執(zhí)行完run方法之后,線程就正常結(jié)束了,線程結(jié)束之后就報(bào)廢了,不能再次start,只能新建一個(gè)線程對(duì)象。
  • 但有時(shí)run方法是永遠(yuǎn)不會(huì)結(jié)束的。例如在程序中使用線程進(jìn)行Socket監(jiān)聽(tīng)請(qǐng)求,或是其他的需要循環(huán)處理的任務(wù)。在這種情況下,一般是將這些任務(wù)放在一個(gè)循環(huán)中,如while循環(huán)。當(dāng)需要結(jié)束線程時(shí),如何退出線程呢?
    有三種方法可以結(jié)束線程:
  1. 使用退出標(biāo)志,使線程正常退出,也就是當(dāng)run方法完成后線程終止
  2. 使用interrupt()方法中斷線程
  3. 使用stop方法強(qiáng)行終止線程(不推薦使用,可能發(fā)生不可預(yù)料的結(jié)果)
    前兩種方法都可以實(shí)現(xiàn)線程的正常退出,也就是要談的優(yōu)雅結(jié)束線程;第3種方法相當(dāng)于電腦斷電關(guān)機(jī)一樣,是不安全的方法。

1. 使用退出標(biāo)志終止線程

使用一個(gè)變量來(lái)控制循環(huán),例如最直接的方法就是設(shè)一個(gè)boolean類(lèi)型的標(biāo)志,并通過(guò)設(shè)置這個(gè)標(biāo)志為true或false來(lái)控制while循環(huán)是否退出。代碼如下:

public class ThreadSafe extends Thread {
    public boolean exit = false; 
    public void run() { 
        while (!exit){
            //do something
        }
    } 
}

定義了一個(gè)退出標(biāo)志exit,當(dāng)exit為true時(shí),while循環(huán)退出,exit的默認(rèn)值為false.在定義exit時(shí),使用了一個(gè)Java關(guān)鍵字volatile,這個(gè)關(guān)鍵字的目的是使exit同步,也就是說(shuō)在同一時(shí)刻只能由一個(gè)線程來(lái)修改exit的值,

2. 使用interrupt()方法終止線程

使用interrupt()方法來(lái)終端線程可分為兩種情況:

  1. 線程處于阻塞狀態(tài)
    如使用了sleep,同步鎖的wait,socket的receiver,accept等方法時(shí),會(huì)使線程處于阻塞狀態(tài)。如果在這時(shí)調(diào)用了線程的interrupt()方法,系統(tǒng)會(huì)拋出一個(gè)InterruptedException異常,代碼中通過(guò)捕獲異常,然后break跳出循環(huán)狀態(tài),使線程正常結(jié)束。
    通常很多人認(rèn)為只要調(diào)用interrupt方法線程就會(huì)結(jié)束,實(shí)際上是錯(cuò)的,一定要先捕獲InterruptedException異常之后通過(guò)break來(lái)跳出循環(huán),才能正常結(jié)束run方法。
    (當(dāng)然如果try在while外面,就不用break了。捕捉到異常就會(huì)結(jié)束線程。)
public class ThreadSafe extends Thread {
    public void run() { 
        while (true){
            try{
                Thread.sleep(5*1000);阻塞5妙
            }catch(InterruptedException e){
                e.printStackTrace();
                break;//捕獲到異常之后,執(zhí)行break跳出循環(huán)。
            }
        }
    } 
}
  1. 線程未進(jìn)入阻塞狀態(tài)
    使用isInterrupted()判斷線程的中斷標(biāo)志來(lái)退出循環(huán),當(dāng)調(diào)用了interrupt()方法時(shí),中斷標(biāo)志就會(huì)置true,和使用自定義的標(biāo)志來(lái)控制循環(huán)是一樣的道理。
public class ThreadSafe extends Thread {
    public void run() { 
        while (!isInterrupted()){
            //do something, but no tthrow InterruptedException
        }
    } 
}

為什么要區(qū)分進(jìn)入阻塞狀態(tài)和和非阻塞狀態(tài)兩種情況呢?
是因?yàn)楫?dāng)阻塞狀態(tài)時(shí),如果有interrupt()發(fā)生,系統(tǒng)除了會(huì)拋出InterruptedException異常外,還會(huì)調(diào)用interrupted()函數(shù),調(diào)用時(shí)能獲取到中斷狀態(tài)是true的狀態(tài),調(diào)用完之后會(huì)復(fù)位中斷狀態(tài)為false,所以異常拋出之后通過(guò)isInterrupted()是獲取不到中斷狀態(tài)是true的狀態(tài),從而不能退出循環(huán),因此在線程未進(jìn)入阻塞的代碼段時(shí)是可以通過(guò)isInterrupted()來(lái)判斷中斷是否發(fā)生來(lái)控制循環(huán),在進(jìn)入阻塞狀態(tài)后要通過(guò)捕獲異常來(lái)退出循環(huán)。因此使用interrupt()來(lái)退出線程的最好的方式應(yīng)該是兩種情況都要考慮:

public class ThreadSafe extends Thread {
    public void run() { 
        while (!isInterrupted()){ //非阻塞過(guò)程中通過(guò)判斷中斷標(biāo)志來(lái)退出
            try{
                Thread.sleep(5*1000);//阻塞過(guò)程捕獲中斷異常來(lái)退出
            }catch(InterruptedException e){
                e.printStackTrace();
                break;//捕獲到異常之后,執(zhí)行break跳出循環(huán)。
            }
        }
    } 
}

然后在需要停止線程的地方調(diào)用threadSafe.interrupted()就能終止線程了。

3. 使用stop()方法終止線程(不推薦)

程序中可以直接使用thread.stop()來(lái)強(qiáng)行終止線程,但是stop方法是很危險(xiǎn)的,就象突然關(guān)閉計(jì)算機(jī)電源,而不是按正常程序關(guān)機(jī)一樣,可能會(huì)產(chǎn)生不可預(yù)料的結(jié)果,不安全主要是:thread.stop()調(diào)用之后,創(chuàng)建子線程的線程就會(huì)拋出ThreadDeatherror的錯(cuò)誤,并且會(huì)釋放子線程所持有的所有鎖。一般任何進(jìn)行加鎖的代碼塊,都是為了保護(hù)數(shù)據(jù)的一致性,如果在調(diào)用thread.stop()后導(dǎo)致了該線程所持有的所有鎖的突然釋放(不可控制),那么被保護(hù)數(shù)據(jù)就有可能呈現(xiàn)不一致性,其他線程在使用這些被破壞的數(shù)據(jù)時(shí),有可能導(dǎo)致一些很奇怪的應(yīng)用程序錯(cuò)誤。因此,并不推薦使用stop方法來(lái)終止線程。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書(shū)系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容