1. 程式人生 > >線程中斷以及線程中斷引發的那些問題

線程中斷以及線程中斷引發的那些問題

開啟 徹底 掌握 oschina 停止 keyword urn rime r+

上周寫了一篇多線程的文章,其實更多方面是偏基礎一點的文章,而且也比較大白話,爭取人人都能看的明白,再舉一些常見的例子,能很好的幫助大家理解多線程,文章發表之後我投給了幾個大號和CSDN反應都挺好的,大家表示希望能寫更多這樣的文章,希望再多寫寫線程相關的文章,所以我打算從線程的基礎開始寫起,每周寫那麽兩三篇,大家閑的時候可以看看,也可以多吸收一點東西。

另外,希望大家在閱讀完之後能來個互動點贊什麽的,也讓我有點創作的動力,另外說說你們的想法什麽的,我也好寫出更好的文章來,廢話不多說了,我們開始今天的知識點學習吧!

什麽是線程中斷?

在我們的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()兩個方法使用不當也會引起線程拋出該異常。

如果大家想學習以上路線內容,在此我向大家推薦一個架構學習交流群。交流學習群號874811168 裏面會分享一些資深架構師錄制的視頻錄像:有Spring,MyBatis,Netty源碼分析,高並發、高性能、分布式、微服務架構的原理,JVM性能優化、分布式架構等這些成為架構師必備的知識體系。還能領取免費的學習資源,目前受益良多

查看線程是否中斷的兩種方式

在Thread類中有一個方法interrupted()可以用來檢查當前線程時候被中斷,還有isInterrupted()方法可以用來檢查當前線程是否被中斷。

中斷線程的方法其實底層就是將這個屬性設置為true,isInterrupted()方法只是返回了這個屬性值而已。

技術分享圖片

這兩個方法有一個區別就是isInterrupted()不能改變interrupted()的屬性值,但是interrupted()方法卻能改變interrupted的屬性值,所以在判斷一個線程時候被中斷的時候我們更推薦使用isInterrupted()。

出處:https://my.oschina.net/u/3178270/blog/2045625

線程中斷以及線程中斷引發的那些問題