本文來學(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);
}
}
這個線程做的事情就是在同步代碼塊中對 i
和 j
這兩個變量進(jìn)行自增操作咒劲,但是在這個執(zhí)行過程中會進(jìn)行 10 秒的睡眠顷蟆,如果在這個過程中,如果用 stop
方法將線程中止的話腐魂,會導(dǎo)致 i
和 j
數(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í)行變量 i
和 j
的自增操作,但是這個自增操作是用同步關(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 class
的 wait() 挣输、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ā)】獲取。