- 線程對象屬于一次性消耗品,一般線程執(zhí)行完run方法之后,線程就正常結束了,線程結束之后就報廢了,不能再次start,只能新建一個線程對象。
- 但有時run方法是永遠不會結束的。例如在程序中使用線程進行Socket監(jiān)聽請求,或是其他的需要循環(huán)處理的任務。在這種情況下,一般是將這些任務放在一個循環(huán)中,如while循環(huán)。當需要結束線程時,如何退出線程呢?
有三種方法可以結束線程:
- 使用退出標志,使線程正常退出,也就是當run方法完成后線程終止
- 使用interrupt()方法中斷線程
- 使用stop方法強行終止線程(不推薦使用,可能發(fā)生不可預料的結果)
前兩種方法都可以實現(xiàn)線程的正常退出,也就是要談的優(yōu)雅結束線程;第3種方法相當于電腦斷電關機一樣,是不安全的方法。
1. 使用退出標志終止線程
使用一個變量來控制循環(huán),例如最直接的方法就是設一個boolean類型的標志,并通過設置這個標志為true或false來控制while循環(huán)是否退出。代碼如下:
public class ThreadSafe extends Thread {
public boolean exit = false;
public void run() {
while (!exit){
//do something
}
}
}
定義了一個退出標志exit,當exit為true時,while循環(huán)退出,exit的默認值為false.在定義exit時,使用了一個Java關鍵字volatile,這個關鍵字的目的是使exit同步,也就是說在同一時刻只能由一個線程來修改exit的值,
2. 使用interrupt()方法終止線程
使用interrupt()方法來終端線程可分為兩種情況:
-
線程處于阻塞狀態(tài)
如使用了sleep,同步鎖的wait,socket的receiver,accept等方法時,會使線程處于阻塞狀態(tài)。如果在這時調(diào)用了線程的interrupt()方法,系統(tǒng)會拋出一個InterruptedException異常,代碼中通過捕獲異常,然后break跳出循環(huán)狀態(tài),使線程正常結束。
通常很多人認為只要調(diào)用interrupt方法線程就會結束,實際上是錯的,一定要先捕獲InterruptedException異常之后通過break來跳出循環(huán),才能正常結束run方法。
(當然如果try在while外面,就不用break了。捕捉到異常就會結束線程。)
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)。
}
}
}
}
-
線程未進入阻塞狀態(tài)
使用isInterrupted()判斷線程的中斷標志來退出循環(huán),當調(diào)用了interrupt()方法時,中斷標志就會置true,和使用自定義的標志來控制循環(huán)是一樣的道理。
public class ThreadSafe extends Thread {
public void run() {
while (!isInterrupted()){
//do something, but no tthrow InterruptedException
}
}
}
為什么要區(qū)分進入阻塞狀態(tài)和和非阻塞狀態(tài)兩種情況呢?
是因為當阻塞狀態(tài)時,如果有interrupt()發(fā)生,系統(tǒng)除了會拋出InterruptedException異常外,還會調(diào)用interrupted()函數(shù),調(diào)用時能獲取到中斷狀態(tài)是true的狀態(tài),調(diào)用完之后會復位中斷狀態(tài)為false,所以異常拋出之后通過isInterrupted()是獲取不到中斷狀態(tài)是true的狀態(tài),從而不能退出循環(huán),因此在線程未進入阻塞的代碼段時是可以通過isInterrupted()來判斷中斷是否發(fā)生來控制循環(huán),在進入阻塞狀態(tài)后要通過捕獲異常來退出循環(huán)。因此使用interrupt()來退出線程的最好的方式應該是兩種情況都要考慮:
public class ThreadSafe extends Thread {
public void run() {
while (!isInterrupted()){ //非阻塞過程中通過判斷中斷標志來退出
try{
Thread.sleep(5*1000);//阻塞過程捕獲中斷異常來退出
}catch(InterruptedException e){
e.printStackTrace();
break;//捕獲到異常之后,執(zhí)行break跳出循環(huán)。
}
}
}
}
然后在需要停止線程的地方調(diào)用threadSafe.interrupted()就能終止線程了。
3. 使用stop()方法終止線程(不推薦)
程序中可以直接使用thread.stop()來強行終止線程,但是stop方法是很危險的,就象突然關閉計算機電源,而不是按正常程序關機一樣,可能會產(chǎn)生不可預料的結果,不安全主要是:thread.stop()調(diào)用之后,創(chuàng)建子線程的線程就會拋出ThreadDeatherror的錯誤,并且會釋放子線程所持有的所有鎖。一般任何進行加鎖的代碼塊,都是為了保護數(shù)據(jù)的一致性,如果在調(diào)用thread.stop()后導致了該線程所持有的所有鎖的突然釋放(不可控制),那么被保護數(shù)據(jù)就有可能呈現(xiàn)不一致性,其他線程在使用這些被破壞的數(shù)據(jù)時,有可能導致一些很奇怪的應用程序錯誤。因此,并不推薦使用stop方法來終止線程。