本篇文章帶給大家的內容是關於Java中執行緒中斷是什麼? Java執行緒中斷會引起哪些問題?有一定的參考價值,有需要的朋友可以參考一下,希望對你有幫助。
什麼是執行緒中斷?
在我們的Java程式中其實有不只一條執行線程,只有當所有的執行緒都運行結束的時候,這個Java程式才算運行結束。官方的話給你描述一下:當所有的非守護執行緒運行結束時,或是其中一個執行緒呼叫了System.exit()方法時,這個Java程式才能運行結束。
線程中斷的應用場景
我們先來舉一個例子,例如我們現在在下載一個500多M的大片,我們點擊開始下載,那個這個時候就等於開啟了一個線程去下載我們的文件,然而這個時候我們的網速不是很給力,幾十KB的在這跑,作為一個年輕人我是等不了了,我不下來,那麼這個時候我們第一個操作就是結束掉這個下載檔案的操作,其實更接近程式的來說,這時候我們就需要把這個線程給中斷了。
我們接下來寫一下這個下載的程式碼,看看如何中斷一個線程,這裡我已經預設你們已經掌握瞭如何創建一個線程了,這段程式我們模擬下載,最開始取得系統時間,然後進入循環每次取得系統時間,如果時間超過10秒我們就中斷線程,不在繼續下載,下載速度時每秒1M:
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()。
以上是Java中線程中斷是什麼? Java執行緒中斷會引起哪些問題?的詳細內容。更多資訊請關注PHP中文網其他相關文章!