什麼是線程中斷?
在我們的Java程式中其實有不止一條執行
線程,隻有當所有的線程都運作結束的時候,這個Java程式才算運作結束。 官方的話給你描述一下:當所有的非守護線程運作結束時,或者其中一個線程調用了System.exit()方法時,這個Java程式才能運作結束。
線程中斷的應用場景
我們先來舉一個例子,比如我們現在在下載下傳一個500多M的大片,我們點選開始下載下傳,那個這個時候就等于開啟了一個線程去下載下傳我們的檔案,然而這個時候我們的網速不是很給力,幾十KB的在這跑,作為一個年輕人我是等不了了,我不下來,那麼這個時候我們第一個操作就是結束掉這個下載下傳檔案的操作,其實更接近程式的來說,這個時候我們就需要把這個線程給中斷了。

public void run() {
int number = 0;
// 記錄程式開始的時間
Long start = System.currentTimeMillis();
while (true) {
// 每次執行一次結束的時間
Long end = System.currentTimeMillis();
// 擷取時間差
Long interval = end - start;
// 如果時間超過了10秒,那麼我們就結束下載下傳
if (interval >= 10000) {
// 中斷線程
interrupted();
System.err.println("太慢了,我不下了");
return;
} else if (number >= 500) {
System.out.println("檔案下載下傳完成");
// 中斷線程
interrupted();
return;
}
number++;
System.out.println("已下載下傳" + number + "M");
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
中斷線程的方式
Thread類中給我們提供了中斷線程的方法,我們先來看下這個方法到底是如何讓線程中斷的:
public static boolean interrupted() {
return currentThread().isInterrupted(true);
}
這個方法是檢查目前線程是否被中斷,中斷傳回true,未中斷傳回false
private native boolean isInterrupted(boolean ClearInterrupted);
通過檢視源碼我們可以發現,中斷線程就是通過調用檢查線程是否被中斷的方法,把值設為true。這個時候你再去調用檢查線程是否中斷的方法時就傳回true了。
這裡大家需要注意一個問題:Thread.interrupted()方法隻是修改了目前線程的狀态告訴他被中斷了,但是對于非阻塞中的線程,隻是改變了中斷狀态,即 Thread.isInterrupted()傳回true,對于可取消的阻塞狀态中的線程,例如等待在這些函數上的線程 ,Thread.sleep(),這個線程收到中斷信号之後就會抛出InterruptedException異常,同時會把中斷狀态設定為true。
線程睡眠引起InterruptedException異常的原因
其實這樣說大家也是一知半解,我就寫一個錯誤的示例,大家來看一下,把這個問題徹底的搞清楚:
public void run() {
int number = 0;
while (true) {
// 檢查線程是否被中斷,中斷就停止下載下傳
if (isInterrupted()) {
System.err.println("太慢了,我不下了");
return;
} else if (number >= 500) {
System.out.println("下載下傳完成");
return;
}
number++;
System.out.println("已下載下傳" + number + "M");
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
這是我們的主程式,等待10秒後中斷線程
public static void main(String[] args) throws InterruptedException {
Thread thread = new PrimeGenerator();
// 啟動線程
thread.start();
// 等待10秒後中斷線程
Thread.sleep(1000);
// 中斷線程
thread.interrupt();
}
看起來很通常的一個程式,但是事實卻并非你看到的樣子,其實這段代碼是會抛出InterruptedException異常的,我們來分析原因。
這裡我們先要了解Thread.interrupt()方法不會中斷一個正在運作的線程,調用Thread.sleep()方法時,這個時候就不再占用CPU,我們來分析下我們這個程式,我們下載下傳是要等待10秒,每次下載下傳的速度是0.5M/S,也就是當我們下載下傳到5M的時候等待時間已經到了,這個時候調用Thread.interrupt()方法中斷線程,但是run()方法中的睡眠還要接着往下執行,它是不會因為中斷而放棄執行下面的代碼的,那麼這個時候當它再執行Thread.sleep()的時候就會抛出InterruptedException異常,因為目前的線程已經被中斷了。
說到這裡,你是否已經明白産生這個異常的原因了?另外還有另外的兩個原因緻使線程産生InterruptedException異常的原因,wait()、join()兩個方法使用不當也會引起線程抛出該異常。
檢視線程是否中斷的兩種方式
在Thread類中有一個方法interrupted()可以用來檢查目前線程時候被中斷,還有isInterrupted()方法可以用來檢查目前線程是否被中斷。
中斷線程的方法其實底層就是将這個屬性設定為true,isInterrupted()方法隻是傳回了這個屬性值而已。
這兩個方法有一個差別就是isInterrupted()不能改變interrupted()的屬性值,但是interrupted()方法卻能改變interrupted的屬性值,是以在判斷一個線程時候被中斷的時候我們更推薦使用isInterrupted()。
文章來源:
https://my.oschina.net/u/3178270/blog/2045625推薦閱讀:
https://www.roncoo.com/article/index?title=%E7%BA%BF%E7%A8%8B