1概述
在Java中有以下3種方法可以終止正在運(yùn)行的線程:
- 1)當(dāng)run方法完成后線程終止玻驻。
- 2)使用stop方法強(qiáng)行終止線程,但是不推薦使用這個(gè)方法户辫,因?yàn)閟top和suspend及resume一樣嗤锉,都是作廢過(guò)期的方法,使用它們可能產(chǎn)生不可預(yù)料的結(jié)果瘟忱。
- 3)使用interrupt方法中斷線程坐昙。
2 stop()方法停止線程
try {
MyThread thread = new MyThread();
thread.start();
Thread.sleep(8000);
thread.stop();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
- 調(diào)用stop()方法時(shí)會(huì)拋出java.lang.ThreadDeath異常,但在通常的情況下陪每,此異常不需要顯式地捕捉兽埃。
- 調(diào)用stop()方法后線程會(huì)立即停止
問(wèn)題 - 方法stop()已經(jīng)被作廢涡相,因?yàn)槿绻麖?qiáng)制讓線程停止則有可能使一些清理性的工作得不到完成。
- 另外一個(gè)情況就是對(duì)鎖定的對(duì)象進(jìn)行了“解鎖”切威,導(dǎo)致數(shù)據(jù)得不到同步的處理生逸,出現(xiàn)數(shù)據(jù)不一致的問(wèn)題且预。
3 調(diào)用interrupt()方法來(lái)停止線程
- 設(shè)置線程的中斷狀態(tài)
- interrupt()方法的使用效果并不像for+break語(yǔ)句那樣,馬上就停止循環(huán)锋谐。
- 調(diào)用interrupt()方法僅僅是在當(dāng)前線程中打了一個(gè)停止的標(biāo)記,并不是真的停止線程乾戏。
3.1 this.interrupted() VS this.isInterrupted()
- this.interrupted():測(cè)試當(dāng)前線程是否已經(jīng)是中斷狀態(tài)三热,執(zhí)行后具有將狀態(tài)標(biāo)志置清除為false的功能。
- this.isInterrupted():測(cè)試線程Thread對(duì)象是否已經(jīng)是中斷狀態(tài)呐能,但不清除狀態(tài)標(biāo)志。
3.2 interrupt方法配合拋出異常停止線程
建議使用“拋異嘲诔觯”的方法來(lái)實(shí)現(xiàn)線程的停止,因?yàn)樵赾atch塊中還可以將異常向上拋爷恳,使線程停止的事件得以傳播象踊。
【Java 多線程】Java中主線程如何捕獲子線程拋出的異常
public class MyThread extends Thread {
@Override
public void run() {
super.run();
try {
for (int i = 0; i < 500000; i++) {
if (this.interrupted()) {
System.out.println("已經(jīng)是停止?fàn)顟B(tài)了!我要退出了!");
throw new InterruptedException();
}
System.out.println("i=" + (i + 1));
}
System.out.println("我在for下面");
} catch (InterruptedException e) {
System.out.println("進(jìn)MyThread.java類(lèi)run方法中的catch了!");
e.printStackTrace();
}
}
}
public class Run {
public static void main(String[] args) {
try {
MyThread thread = new MyThread();
thread.start();
Thread.sleep(2000);
thread.interrupt();
} catch (InterruptedException e) {
System.out.println("main catch");
e.printStackTrace();
}
System.out.println("end!");
}
}
3.3 interrupt方法 配合 return 停止線程
程序正常執(zhí)行完成,線程退出菊碟。
public class MyThread extends Thread {
@Override
public void run() {
while (true) {
if (this.isInterrupted()) {
System.out.println("停止了!");
return;
}
System.out.println("timer=" + System.currentTimeMillis());
}
}
}
public class Run {
public static void main(String[] args) throws InterruptedException {
MyThread t=new MyThread();
t.start();
Thread.sleep(2000);
t.interrupt();
}
}
3.4 注意
- 如果線程在調(diào)用 Object 類(lèi)的 wait()逆害、wait(long) 或 wait(long, int) 方法,或者該類(lèi)的 join()魄幕、join(long)、join(long, int)坛芽、sleep(long) 或 sleep(long, int) 方法過(guò)程中受阻翼抠,則其中斷狀態(tài)將被清除,它還將收到一個(gè)
InterruptedException
活喊。 - 如果該線程在可中斷的通道上的 I/O 操作中受阻量愧,則該通道將被關(guān)閉,該線程的中斷狀態(tài)將被設(shè)置并且該線程將收到一個(gè)
ClosedByInterruptException
偎肃。
參考
《java多線程編程核心技術(shù)》