Java線(xiàn)程的生命周期和狀態(tài)控制_動(dòng)力節(jié)點(diǎn)Java學(xué)院整理
一、線(xiàn)程的生命周期
線(xiàn)程狀態(tài)轉(zhuǎn)換圖:

1、新建狀態(tài)
用new關(guān)鍵字和Thread類(lèi)或其子類(lèi)建立一個(gè)線(xiàn)程對(duì)象后,該線(xiàn)程對(duì)象就處于新生狀態(tài)。處于新生狀態(tài)的線(xiàn)程有自己的內(nèi)存空間,通過(guò)調(diào)用start方法進(jìn)入就緒狀態(tài)(runnable)。
注意:不能對(duì)已經(jīng)啟動(dòng)的線(xiàn)程再次調(diào)用start()方法,否則會(huì)出現(xiàn)Javalang.IllegalThreadStateException異常。
2、就緒狀態(tài)
處于就緒狀態(tài)的線(xiàn)程已經(jīng)具備了運(yùn)行條件,但還沒(méi)有分配到CPU,處于線(xiàn)程就緒隊(duì)列(盡管是采用隊(duì)列形式,事實(shí)上,把它稱(chēng)為可運(yùn)行池而不是可運(yùn)行隊(duì)列。因?yàn)閏pu的調(diào)度不一定是按照先進(jìn)先出的順序來(lái)調(diào)度的),等待系統(tǒng)為其分配CPU。等待狀態(tài)并不是執(zhí)行狀態(tài),當(dāng)系統(tǒng)選定一個(gè)等待執(zhí)行的Thread對(duì)象后,它就會(huì)從等待執(zhí)行狀態(tài)進(jìn)入執(zhí)行狀態(tài),系統(tǒng)挑選的動(dòng)作稱(chēng)之為“cpu調(diào)度”。一旦獲得CPU,線(xiàn)程就進(jìn)入運(yùn)行狀態(tài)并自動(dòng)調(diào)用自己的run方法。
提示:如果希望子線(xiàn)程調(diào)用start()方法后立即執(zhí)行,可以使用Thread.sleep()方式使主線(xiàn)程睡眠一伙兒,轉(zhuǎn)去執(zhí)行子線(xiàn)程。
3、運(yùn)行狀態(tài)
處于運(yùn)行狀態(tài)的線(xiàn)程最為復(fù)雜,它可以變?yōu)樽枞麪顟B(tài)、就緒狀態(tài)和死亡狀態(tài)。處于就緒狀態(tài)的線(xiàn)程,如果獲得了cpu的調(diào)度,就會(huì)從就緒狀態(tài)變?yōu)檫\(yùn)行狀態(tài),執(zhí)行run()方法中的任務(wù)。如果該線(xiàn)程失去了cpu資源,就會(huì)又從運(yùn)行狀態(tài)變?yōu)榫途w狀態(tài)。重新等待系統(tǒng)分配資源。也可以對(duì)在運(yùn)行狀態(tài)的線(xiàn)程調(diào)用yield()方法,它就會(huì)讓出cpu資源,再次變?yōu)榫途w狀態(tài)。
當(dāng)發(fā)生如下情況是,線(xiàn)程會(huì)從運(yùn)行狀態(tài)變?yōu)樽枞麪顟B(tài):
①、線(xiàn)程調(diào)用sleep方法主動(dòng)放棄所占用的系統(tǒng)資源
②、線(xiàn)程調(diào)用一個(gè)阻塞式IO方法,在該方法返回之前,該線(xiàn)程被阻塞
③、線(xiàn)程試圖獲得一個(gè)同步監(jiān)視器,但更改同步監(jiān)視器正被其他線(xiàn)程所持有
④、線(xiàn)程在等待某個(gè)通知(notify)
⑤、程序調(diào)用了線(xiàn)程的suspend方法將線(xiàn)程掛起。不過(guò)該方法容易導(dǎo)致死鎖,所以程序應(yīng)該盡量避免使用該方法。
當(dāng)線(xiàn)程的run()方法執(zhí)行完,或者被強(qiáng)制性地終止,例如出現(xiàn)異常,或者調(diào)用了stop()、desyory()方法等等,就會(huì)從運(yùn)行狀態(tài)轉(zhuǎn)變?yōu)樗劳鰻顟B(tài)。
4、阻塞狀態(tài)
處于運(yùn)行狀態(tài)的線(xiàn)程在某些情況下,如執(zhí)行了sleep(睡眠)方法,或等待I/O設(shè)備等資源,將讓出CPU并暫時(shí)停止自己的運(yùn)行,進(jìn)入阻塞狀態(tài)。
在阻塞狀態(tài)的線(xiàn)程不能進(jìn)入就緒隊(duì)列。只有當(dāng)引起阻塞的原因消除時(shí),如睡眠時(shí)間已到,或等待的I/O設(shè)備空閑下來(lái),線(xiàn)程便轉(zhuǎn)入就緒狀態(tài),重新到就緒隊(duì)列中排隊(duì)等待,被系統(tǒng)選中后從原來(lái)停止的位置開(kāi)始繼續(xù)運(yùn)行。
5、死亡狀態(tài)
當(dāng)線(xiàn)程的run()方法執(zhí)行完,或者被強(qiáng)制性地終止,就認(rèn)為它死去。這個(gè)線(xiàn)程對(duì)象也許是活的,但是,它已經(jīng)不是一個(gè)單獨(dú)執(zhí)行的線(xiàn)程。線(xiàn)程一旦死亡,就不能復(fù)生。 如果在一個(gè)死去的線(xiàn)程上調(diào)用start()方法,會(huì)拋出java.lang.IllegalThreadStateException異常。
二、線(xiàn)程狀態(tài)的控制
Java提供了一些便捷的方法用于會(huì)線(xiàn)程狀態(tài)的控制。
.
可以看到很多方法,已經(jīng)標(biāo)注為過(guò)時(shí)的,我們應(yīng)該盡可能的避免使用它們,而應(yīng)該重點(diǎn)關(guān)注start()、interrupt()、join()、sleep()、yield()等直接控制方法,和setDaemon()、setPriority()等間接控制方法。
1、線(xiàn)程睡眠——sleep
如果我們需要讓當(dāng)前正在執(zhí)行的線(xiàn)程暫停一段時(shí)間,并進(jìn)入阻塞狀態(tài),則可以通過(guò)調(diào)用Thread的sleep方法,從上面可以看到sleep方法有兩種重載的形式,但是使用方法一樣。
比如,我們想要使主線(xiàn)程每休眠100毫秒,然后再打印出數(shù)字:
public class Test {
public static void main(String[] args) throws InterruptedException {
for(int i=;i<;i++){
System.out.println("main"+i);
Thread.sleep();
}
}
}
可以明顯看到打印的數(shù)字在時(shí)間上有些許的間隔。
注意如下幾點(diǎn)問(wèn)題
①、sleep是靜態(tài)方法,最好不要用Thread的實(shí)例對(duì)象調(diào)用它,因?yàn)樗叩氖冀K是當(dāng)前正在運(yùn)行的線(xiàn)程,而不是調(diào)用它的線(xiàn)程對(duì)象,它只對(duì)正在運(yùn)行狀態(tài)的線(xiàn)程對(duì)象有效??聪旅娴睦樱?/p>
public class Test1 {
public static void main(String[] args) throws InterruptedException {
System.out.println(Thread.currentThread().getName());
MyThread myThread=new MyThread();
myThread.start();
myThread.sleep(1000);//這里sleep的就是main線(xiàn)程,而非myThread線(xiàn)程
Thread.sleep(10);
for(int i=0;i<100;i++){
System.out.println("main"+i);
}
}
}
②、Java線(xiàn)程調(diào)度是Java多線(xiàn)程的核心,只有良好的調(diào)度,才能充分發(fā)揮系統(tǒng)的性能,提高程序的執(zhí)行效率。但是不管程序員怎么編寫(xiě)調(diào)度,只能最大限度的影響線(xiàn)程執(zhí)行的次序,而不能做到精準(zhǔn)控制。因?yàn)槭褂胹leep方法之后,線(xiàn)程是進(jìn)入阻塞狀態(tài)的,只有當(dāng)睡眠的時(shí)間結(jié)束,才會(huì)重新進(jìn)入到就緒狀態(tài),而就緒狀態(tài)進(jìn)入到運(yùn)行狀態(tài),是由系統(tǒng)控制的,我們不可能精準(zhǔn)的去干涉它,所以如果調(diào)用Thread.sleep(1000)使得線(xiàn)程睡眠1秒,可能結(jié)果會(huì)大于1秒。
public class Test1 {
public static void main(String[] args) throws InterruptedException {
new MyThread().start();
new MyThread().start();
}
}
class MyThread extends Thread {
@Override
public void run() {
for (int i = 0; i < 3; i++) {
System.out.println(this.getName()+"線(xiàn)程" + i + "次執(zhí)行!");
try {
Thread.sleep(50);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
看某一次的運(yùn)行結(jié)果:
1. Thread-0線(xiàn)程0次執(zhí)行!
2. Thread-1線(xiàn)程0次執(zhí)行!
3. Thread-1線(xiàn)程1次執(zhí)行!
4. Thread-0線(xiàn)程1次執(zhí)行!
5. Thread-0線(xiàn)程2次執(zhí)行!
6. Thread-1線(xiàn)程2次執(zhí)行!
可以看到,線(xiàn)程0首先執(zhí)行,然后線(xiàn)程1執(zhí)行一次,又了執(zhí)行一次??梢钥吹剿⒉皇前凑誷leep的順序執(zhí)行的。
2、線(xiàn)程讓步——yield
yield()方法和sleep()方法有點(diǎn)相似,它也是Thread類(lèi)提供的一個(gè)靜態(tài)的方法,它也可以讓當(dāng)前正在執(zhí)行的線(xiàn)程暫停,讓出cpu資源給其他的線(xiàn)程。但是和sleep()方法不同的是,它不會(huì)進(jìn)入到阻塞狀態(tài),而是進(jìn)入到就緒狀態(tài)。yield()方法只是讓當(dāng)前線(xiàn)程暫停一下,重新進(jìn)入就緒的線(xiàn)程池中,讓系統(tǒng)的線(xiàn)程調(diào)度器重新調(diào)度器重新調(diào)度一次,完全可能出現(xiàn)這樣的情況:當(dāng)某個(gè)線(xiàn)程調(diào)用yield()方法之后,線(xiàn)程調(diào)度器又將其調(diào)度出來(lái)重新進(jìn)入到運(yùn)行狀態(tài)執(zhí)行。
實(shí)際上,當(dāng)某個(gè)線(xiàn)程調(diào)用了yield()方法暫停之后,優(yōu)先級(jí)與當(dāng)前線(xiàn)程相同,或者優(yōu)先級(jí)比當(dāng)前線(xiàn)程更高的就緒狀態(tài)的線(xiàn)程更有可能獲得執(zhí)行的機(jī)會(huì),當(dāng)然,只是有可能,因?yàn)槲覀儾豢赡芫_的干涉cpu調(diào)度線(xiàn)程。
yield的用法:
public class Test1 {
public static void main(String[] args) throws InterruptedException {
new MyThread("低級(jí)", 1).start();
new MyThread("中級(jí)", 5).start();
new MyThread("高級(jí)", 10).start();
}
}
class MyThread extends Thread {
public MyThread(String name, int pro) {
super(name);// 設(shè)置線(xiàn)程的名稱(chēng)
this.setPriority(pro);// 設(shè)置優(yōu)先級(jí)
}
@Override
public void run() {
for (int i = 0; i < 30; i++) {
System.out.println(this.getName() + "線(xiàn)程第" + i + "次執(zhí)行!");
if (i % 5 == 0)
Thread.yield();
}
}
}
關(guān)于sleep()方法和yield()方的區(qū)別如下:
①、sleep方法暫停當(dāng)前線(xiàn)程后,會(huì)進(jìn)入阻塞狀態(tài),只有當(dāng)睡眠時(shí)間到了,才會(huì)轉(zhuǎn)入就緒狀態(tài)。而yield方法調(diào)用后 ,是直接進(jìn)入就緒狀態(tài),所以有可能剛進(jìn)入就緒狀態(tài),又被調(diào)度到運(yùn)行狀態(tài)。
②、sleep方法聲明拋出了InterruptedException,所以調(diào)用sleep方法的時(shí)候要捕獲該異常,或者顯示聲明拋出該異常。而yield方法則沒(méi)有聲明拋出任務(wù)異常。
③、sleep方法比yield方法有更好的可移植性,通常不要依靠yield方法來(lái)控制并發(fā)線(xiàn)程的執(zhí)行。
3、線(xiàn)程合并——join
線(xiàn)程的合并的含義就是將幾個(gè)并行線(xiàn)程的線(xiàn)程合并為一個(gè)單線(xiàn)程執(zhí)行,應(yīng)用場(chǎng)景是當(dāng)一個(gè)線(xiàn)程必須等待另一個(gè)線(xiàn)程執(zhí)行完畢才能執(zhí)行時(shí),Thread類(lèi)提供了join方法來(lái)完成這個(gè)功能,注意,它不是靜態(tài)方法。
從上面的方法的列表可以看到,它有3個(gè)重載的方法:
void join()
當(dāng)前線(xiàn)程等該加入該線(xiàn)程后面,等待該線(xiàn)程終止。
void join(long millis)
當(dāng)前線(xiàn)程等待該線(xiàn)程終止的時(shí)間最長(zhǎng)為 millis 毫秒。 如果在millis時(shí)間內(nèi),該線(xiàn)程沒(méi)有執(zhí)行完,那么當(dāng)前線(xiàn)程進(jìn)入就緒狀態(tài),重新等待cpu調(diào)度
void join(long millis,int nanos)
等待該線(xiàn)程終止的時(shí)間最長(zhǎng)為 millis 毫秒 + nanos 納秒。如果在millis時(shí)間內(nèi),該線(xiàn)程沒(méi)有執(zhí)行完,那么當(dāng)前線(xiàn)程進(jìn)入就緒狀態(tài),重新等待cpu調(diào)度
例子:
public class Test1 {
public static void main(String[] args) throws InterruptedException {
MyThread thread=new MyThread();
thread.start();
thread.join(1);//將主線(xiàn)程加入到子線(xiàn)程后面,不過(guò)如果子線(xiàn)程在1毫秒時(shí)間內(nèi)沒(méi)執(zhí)行完,則主線(xiàn)程便不再等待它執(zhí)行完,進(jìn)入就緒狀態(tài),等待cpu調(diào)度
for(int i=0;i<30;i++){
System.out.println(Thread.currentThread().getName() + "線(xiàn)程第" + i + "次執(zhí)行!");
}
}
}
class MyThread extends Thread {
@Override
public void run() {
for (int i = 0; i < 1000; i++) {
System.out.println(this.getName() + "線(xiàn)程第" + i + "次執(zhí)行!");
}
}
}
在這個(gè)例子中,在主線(xiàn)程中調(diào)用thread.join(); 就是將主線(xiàn)程加入到thread子線(xiàn)程后面等待執(zhí)行。不過(guò)有時(shí)間限制,為1毫秒。
4、線(xiàn)程的優(yōu)先級(jí)
每個(gè)線(xiàn)程執(zhí)行時(shí)都有一個(gè)優(yōu)先級(jí)的屬性,優(yōu)先級(jí)高的線(xiàn)程可以獲得較多的執(zhí)行機(jī)會(huì),而優(yōu)先級(jí)低的線(xiàn)程則獲得較少的執(zhí)行機(jī)會(huì)。與線(xiàn)程休眠類(lèi)似,線(xiàn)程的優(yōu)先級(jí)仍然無(wú)法保障線(xiàn)程的執(zhí)行次序。只不過(guò),優(yōu)先級(jí)高的線(xiàn)程獲取CPU資源的概率較大,優(yōu)先級(jí)低的也并非沒(méi)機(jī)會(huì)執(zhí)行。
每個(gè)線(xiàn)程默認(rèn)的優(yōu)先級(jí)都與創(chuàng)建它的父線(xiàn)程具有相同的優(yōu)先級(jí),在默認(rèn)情況下,main線(xiàn)程具有普通優(yōu)先級(jí)。
Thread類(lèi)提供了setPriority(int newPriority)和getPriority()方法來(lái)設(shè)置和返回一個(gè)指定線(xiàn)程的優(yōu)先級(jí),其中setPriority方法的參數(shù)是一個(gè)整數(shù),范圍是1~•0之間,也可以使用Thread類(lèi)提供的三個(gè)靜態(tài)常量:
- MAX_PRIORITY =10
- MIN_PRIORITY =1
- NORM_PRIORITY =5
例子:
public class Test1 {
public static void main(String[] args) throws InterruptedException {
new MyThread("高級(jí)", 10).start();
new MyThread("低級(jí)", 1).start();
}
}
class MyThread extends Thread {
public MyThread(String name,int pro) {
super(name);//設(shè)置線(xiàn)程的名稱(chēng)
setPriority(pro);//設(shè)置線(xiàn)程的優(yōu)先級(jí)
}
@Override
public void run() {
for (int i = 0; i < 100; i++) {
System.out.println(this.getName() + "線(xiàn)程第" + i + "次執(zhí)行!");
}
}
}
從結(jié)果可以看到 ,一般情況下,高級(jí)線(xiàn)程更顯執(zhí)行完畢。
注意一點(diǎn):雖然Java提供了10個(gè)優(yōu)先級(jí)別,但這些優(yōu)先級(jí)別需要操作系統(tǒng)的支持。不同的操作系統(tǒng)的優(yōu)先級(jí)并不相同,而且也不能很好的和Java的10個(gè)優(yōu)先級(jí)別對(duì)應(yīng)。所以我們應(yīng)該使用MAX_PRIORITY、MIN_PRIORITY和NORM_PRIORITY三個(gè)靜態(tài)常量來(lái)設(shè)定優(yōu)先級(jí),這樣才能保證程序最好的可移植性。
5、守護(hù)線(xiàn)程
守護(hù)線(xiàn)程與普通線(xiàn)程寫(xiě)法上基本么啥區(qū)別,調(diào)用線(xiàn)程對(duì)象的方法setDaemon(true),則可以將其設(shè)置為守護(hù)線(xiàn)程。
守護(hù)線(xiàn)程使用的情況較少,但并非無(wú)用,舉例來(lái)說(shuō),JVM的垃圾回收、內(nèi)存管理等線(xiàn)程都是守護(hù)線(xiàn)程。還有就是在做數(shù)據(jù)庫(kù)應(yīng)用時(shí)候,使用的數(shù)據(jù)庫(kù)連接池,連接池本身也包含著很多后臺(tái)線(xiàn)程,監(jiān)控連接個(gè)數(shù)、超時(shí)時(shí)間、狀態(tài)等等。
setDaemon方法的詳細(xì)說(shuō)明:
public final void setDaemon(boolean on)將該線(xiàn)程標(biāo)記為守護(hù)線(xiàn)程或用戶(hù)線(xiàn)程。當(dāng)正在運(yùn)行的線(xiàn)程都是守護(hù)線(xiàn)程時(shí),Java 虛擬機(jī)退出。
該方法必須在啟動(dòng)線(xiàn)程前調(diào)用。 該方法首先調(diào)用該線(xiàn)程的 checkAccess 方法,且不帶任何參數(shù)。這可能拋出 SecurityException(在當(dāng)前線(xiàn)程中)。
參數(shù):
on - 如果為 true,則將該線(xiàn)程標(biāo)記為守護(hù)線(xiàn)程。
拋出:
IllegalThreadStateException - 如果該線(xiàn)程處于活動(dòng)狀態(tài)。
SecurityException - 如果當(dāng)前線(xiàn)程無(wú)法修改該線(xiàn)程。
/**
* Java線(xiàn)程:線(xiàn)程的調(diào)度-守護(hù)線(xiàn)程
*/
public class Test {
public static void main(String[] args) {
Thread t1 = new MyCommon();
Thread t2 = new Thread(new MyDaemon());
t2.setDaemon(true); //設(shè)置為守護(hù)線(xiàn)程
t2.start();
t1.start();
}
}
class MyCommon extends Thread {
public void run() {
for (int i = 0; i < 5; i++) {
System.out.println("線(xiàn)程1第" + i + "次執(zhí)行!");
try {
Thread.sleep(7);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
class MyDaemon implements Runnable {
public void run() {
for (long i = 0; i < 9999999L; i++) {
System.out.println("后臺(tái)線(xiàn)程第" + i + "次執(zhí)行!");
try {
Thread.sleep(7);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
執(zhí)行結(jié)果:
1. 后臺(tái)線(xiàn)程第0次執(zhí)行!
2. 線(xiàn)程1第0次執(zhí)行!
3. 線(xiàn)程1第1次執(zhí)行!
4. 后臺(tái)線(xiàn)程第1次執(zhí)行!
5. 后臺(tái)線(xiàn)程第2次執(zhí)行!
6. 線(xiàn)程1第2次執(zhí)行!
7. 線(xiàn)程1第3次執(zhí)行!
8. 后臺(tái)線(xiàn)程第3次執(zhí)行!
9. 線(xiàn)程1第4次執(zhí)行!
10. 后臺(tái)線(xiàn)程第4次執(zhí)行!
11. 后臺(tái)線(xiàn)程第5次執(zhí)行!
12. 后臺(tái)線(xiàn)程第6次執(zhí)行!
13. 后臺(tái)線(xiàn)程第7次執(zhí)行!
從上面的執(zhí)行結(jié)果可以看出:前臺(tái)線(xiàn)程是保證執(zhí)行完畢的,后臺(tái)線(xiàn)程還沒(méi)有執(zhí)行完畢就退出了。
實(shí)際上:JRE判斷程序是否執(zhí)行結(jié)束的標(biāo)準(zhǔn)是所有的前臺(tái)執(zhí)線(xiàn)程行完畢了,而不管后臺(tái)線(xiàn)程的狀態(tài),因此,在使用后臺(tái)縣城時(shí)候一定要注意這個(gè)問(wèn)題。
守護(hù)線(xiàn)程的用途:
守護(hù)線(xiàn)程通常用于執(zhí)行一些后臺(tái)作業(yè),例如在你的應(yīng)用程序運(yùn)行時(shí)播放背景音樂(lè),在文字編輯器里做自動(dòng)語(yǔ)法檢查、自動(dòng)保存等功能。Java的垃圾回收也是一個(gè)守護(hù)線(xiàn)程。守護(hù)線(xiàn)的好處就是你不需要關(guān)心它的結(jié)束問(wèn)題。例如你在你的應(yīng)用程序運(yùn)行的時(shí)候希望播放背景音樂(lè),如果將這個(gè)播放背景音樂(lè)的線(xiàn)程設(shè)定為非守護(hù)線(xiàn)程,那么在用戶(hù)請(qǐng)求退出的時(shí)候,不僅要退出主線(xiàn)程,還要通知播放背景音樂(lè)的線(xiàn)程退出;如果設(shè)定為守護(hù)線(xiàn)程則不需要了。
6、如何結(jié)束一個(gè)線(xiàn)程
Thread.stop()、Thread.suspend、Thread.resume、Runtime.runFinalizersOnExit這些終止線(xiàn)程運(yùn)行的方法已經(jīng)被廢棄了,使用它們是極端不安全的!想要安全有效的結(jié)束一個(gè)線(xiàn)程,可以使用下面的方法。
1、正常執(zhí)行完run方法,然后結(jié)束掉
2、控制循環(huán)條件和判斷條件的標(biāo)識(shí)符來(lái)結(jié)束掉線(xiàn)程
比如說(shuō)run方法這樣寫(xiě):
class MyThread extends Thread {
int i=0;
@Override
public void run() {
while (true) {
if(i==10)
break;
i++;
System.out.println(i);
}
}
}
或者
class MyThread extends Thread {
int i=0;
boolean next=true;
@Override
public void run() {
while (next) {
if(i==10)
next=false;
i++;
System.out.println(i);
}
}
}
或者
class MyThread extends Thread {
int i=0;
@Override
public void run() {
while (true) {
if(i==10)
return;
i++;
System.out.println(i);
}
}
}
只要保證在一定的情況下,run方法能夠執(zhí)行完畢即可。而不是while(true)的無(wú)線(xiàn)循環(huán)。
3、使用interrupt結(jié)束一個(gè)線(xiàn)程。
誠(chéng)然,使用第2中方法的標(biāo)識(shí)符來(lái)結(jié)束一個(gè)線(xiàn)程,是一個(gè)不錯(cuò)的方法,但是如果,該線(xiàn)程是處于sleep、wait、join的狀態(tài)的時(shí)候,while循環(huán)就不會(huì)執(zhí)行,那么我們的標(biāo)識(shí)符就無(wú)用武之地了,當(dāng)然也不能再通過(guò)它來(lái)結(jié)束處于這3種狀態(tài)的線(xiàn)程了。
可以使用interrupt這個(gè)巧妙的方式結(jié)束掉這個(gè)線(xiàn)程。
我們看看sleep、wait、join方法的聲明:
public final void wait() throws InterruptedException public static native void sleep(long millis) throws InterruptedException public final void join() throws InterruptedException
可以看到,這三者有一個(gè)共同點(diǎn),都拋出了一個(gè)InterruptedException的異常。
在什么時(shí)候會(huì)產(chǎn)生這樣一個(gè)異常呢?
每個(gè)Thread都有一個(gè)中斷狀狀態(tài),默認(rèn)為false??梢酝ㄟ^(guò)Thread對(duì)象的isInterrupted()方法來(lái)判斷該線(xiàn)程的中斷狀態(tài)??梢酝ㄟ^(guò)Thread對(duì)象的interrupt()方法將中斷狀態(tài)設(shè)置為true。
當(dāng)一個(gè)線(xiàn)程處于sleep、wait、join這三種狀態(tài)之一的時(shí)候,如果此時(shí)他的中斷狀態(tài)為true,那么它就會(huì)拋出一個(gè)InterruptedException的異常,并將中斷狀態(tài)重新設(shè)置為false。
看下面的簡(jiǎn)單的例子:
public class Test1 {
public static void main(String[] args) throws InterruptedException {
MyThread thread=new MyThread();
thread.start();
}
}
class MyThread extends Thread {
int i=1;
@Override
public void run() {
while (true) {
System.out.println(i);
System.out.println(this.isInterrupted());
try {
System.out.println("我馬上去sleep了");
Thread.sleep(2000);
this.interrupt();
} catch (InterruptedException e) {
System.out.println("異常捕獲了"+this.isInterrupted());
return;
}
i++;
}
}
}
測(cè)試結(jié)果:
1. 1
2. false
3. 我馬上去sleep了
4. 2
5. true
6. 我馬上去sleep了
7. 異常捕獲了false
可以看到,首先執(zhí)行第一次while循環(huán),在第一次循環(huán)中,睡眠2秒,然后將中斷狀態(tài)設(shè)置為true。當(dāng)進(jìn)入到第二次循環(huán)的時(shí)候,中斷狀態(tài)就是第一次設(shè)置的true,當(dāng)它再次進(jìn)入sleep的時(shí)候,馬上就拋出了InterruptedException異常,然后被我們捕獲了。然后中斷狀態(tài)又被重新自動(dòng)設(shè)置為false了(從最后一條輸出可以看出來(lái))。
所以,我們可以使用interrupt方法結(jié)束一個(gè)線(xiàn)程。具體使用如下:
public class Test1 {
public static void main(String[] args) throws InterruptedException {
MyThread thread=new MyThread();
thread.start();
Thread.sleep(3000);
thread.interrupt();
}
}
class MyThread extends Thread {
int i=0;
@Override
public void run() {
while (true) {
System.out.println(i);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
System.out.println("中斷異常被捕獲了");
return;
}
i++;
}
}
}
多測(cè)試幾次,會(huì)發(fā)現(xiàn)一般有兩種執(zhí)行結(jié)果:
0
1
2
4. 中斷異常被捕獲了
或者
0
1
2
3
5. 中斷異常被捕獲了
這兩種結(jié)果恰恰說(shuō)明了 只要一個(gè)線(xiàn)程的中斷狀態(tài)一旦為true,只要它進(jìn)入sleep等狀態(tài),或者處于sleep狀態(tài),立馬回拋出InterruptedException異常。
第一種情況,是當(dāng)主線(xiàn)程從3秒睡眠狀態(tài)醒來(lái)之后,調(diào)用了子線(xiàn)程的interrupt方法,此時(shí)子線(xiàn)程正處于sleep狀態(tài),立馬拋出InterruptedException異常。
第一種情況,是當(dāng)主線(xiàn)程從3秒睡眠狀態(tài)醒來(lái)之后,調(diào)用了子線(xiàn)程的interrupt方法,此時(shí)子線(xiàn)程還沒(méi)有處于sleep狀態(tài)。然后再第3次while循環(huán)的時(shí)候,在此進(jìn)入sleep狀態(tài),立馬拋出InterruptedException異常。
相關(guān)文章
Java實(shí)現(xiàn)Dijkstra輸出最短路徑的實(shí)例
這篇文章主要介紹了Java實(shí)現(xiàn)Dijkstra輸出最短路徑的實(shí)例的相關(guān)資料,希望通過(guò)本文能幫助到大家,需要的朋友可以參考下2017-09-09
詳解Java編譯優(yōu)化之循環(huán)展開(kāi)和粗化鎖
之前在講JIT的時(shí)候,有提到在編譯過(guò)程中的兩種優(yōu)化循環(huán)展開(kāi)和粗化鎖,今天從Assembly的角度來(lái)驗(yàn)證一下這兩種編譯優(yōu)化方法,快來(lái)看看吧。2021-06-06
Mybatis Plus LambdaQueryWrapper的具體用法
Mybatis Plus 在其基礎(chǔ)上擴(kuò)展了 LambdaQueryWrapper,LambdaQueryWrapper 提供了更加簡(jiǎn)便的查詢(xún)語(yǔ)法,同時(shí)也避免了SQL注入的風(fēng)險(xiǎn),感興趣的可以了解一下2023-11-11
Java算法練習(xí)題,每天進(jìn)步一點(diǎn)點(diǎn)(2)
方法下面小編就為大家?guī)?lái)一篇Java算法的一道練習(xí)題(分享)。小編覺(jué)得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧,希望可以幫到你2021-07-07
Mybatis如何根據(jù)List批量查詢(xún)List結(jié)果
這篇文章主要介紹了Mybatis如何根據(jù)List批量查詢(xún)List結(jié)果,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-03-03

