5個步驟,教你瞬間明白線程和線程安全

什么是線程中斷?

在我們的Java程序中其實有不止一條執(zhí)行線程,只有當(dāng)所有的線程都運行結(jié)束的時候,這個Java程序才算運行結(jié)束。 官方的話給你描述一下:當(dāng)所有的非守護線程運行結(jié)束時,或者其中一個線程調(diào)用了System.exit()方法時,這個Java程序才能運行結(jié)束。

線程中斷的應(yīng)用場景

我們先來舉一個例子,比如我們現(xiàn)在在下載一個500多M的大片,我們點擊開始下載,那個這個時候就等于開啟了一個線程去下載我們的文件,然而這個時候我們的網(wǎng)速不是很給力,幾十KB的在這跑,作為一個年輕人我是等不了了,我不下來,那么這個時候我們第一個操作就是結(jié)束掉這個下載文件的操作,其實更接近程序的來說,這個時候我們就需要把這個線程給中斷了。

我們接下來寫一下這個下載的代碼,看一下如何中斷一個線程,這里我已經(jīng)默認你們已經(jīng)掌握了如何創(chuàng)建一個線程了,這段程序我們模擬下載,最開始獲取系統(tǒng)時間,然后進入循環(huán)每次獲取系統(tǒng)時間,如果時間超過10秒我們就中斷線程,不在繼續(xù)下載,下載速度時每秒1M:

publicvoidrun()?{intnumber?=0;//?記錄程序開始的時間?Longstart?=?System.currentTimeMillis();while(true)?{//?每次執(zhí)行一次結(jié)束的時間?Longend?=?System.currentTimeMillis();//?獲取時間差?Longinterval?=?end?-?start;//?如果時間超過了10秒,那么我們就結(jié)束下載?if(interval?>=10000)?{//?中斷線程?interrupted();????????????????System.err.println("太慢了,我不下了");return;????????????}elseif(number?>=500)?{????????????????System.out.println("文件下載完成");//?中斷線程?interrupted();return;????????????}?????????????number++;????????????System.out.println("已下載"+?number?+"M");try{????????????????Thread.sleep(2000);????????????}catch(InterruptedException?e)?{????????????????e.printStackTrace();????????????}????????}????}

中斷線程的方式

Thread類中給我們提供了中斷線程的方法,我們先來看下這個方法到底是如何讓線程中斷的:

publicstaticbooleaninterrupted(){returncurrentThread().isInterrupted(true);????}

這個方法是檢查當(dāng)前線程是否被中斷,中斷返回true,未中斷返回false

privatenativebooleanisInterrupted(booleanClearInterrupted);

通過查看源碼我們可以發(fā)現(xiàn),中斷線程就是通過調(diào)用檢查線程是否被中斷的方法,把值設(shè)為true。這個時候你再去調(diào)用檢查線程是否中斷的方法時就返回true了。

這里大家需要注意一個問題:Thread.interrupted()方法只是修改了當(dāng)前線程的狀態(tài)告訴他被中斷了,但是對于非阻塞中的線程,只是改變了中斷狀態(tài),即 Thread.isInterrupted()返回true,對于可取消的阻塞狀態(tài)中的線程,例如等待在這些函數(shù)上的線程 ,Thread.sleep(),這個線程收到中斷信號之后就會拋出InterruptedException異常,同時會把中斷狀態(tài)設(shè)置為true。

線程睡眠引起InterruptedException異常的原因

其實這樣說大家也是一知半解,我就寫一個錯誤的示例,大家來看一下,把這個問題徹底的搞清楚:

publicvoidrun()?{intnumber?=0;while(true)?{//?檢查線程是否被中斷,中斷就停止下載?if(isInterrupted())?{?????????????????System.err.println("太慢了,我不下了");return;????????????}elseif(number?>=500)?{????????????????System.out.println("下載完成");return;????????????}?????????????number++;????????????System.out.println("已下載"+?number?+"M");try{????????????????Thread.sleep(2000);????????????}catch(InterruptedException?e)?{????????????????e.printStackTrace();????????????}????????}????}

這是我們的主程序,等待10秒后中斷線程

publicstaticvoidmain(String[]?args)throwsInterruptedException{?????????Thread?thread?=newPrimeGenerator();//?啟動線程?thread.start();//?等待10秒后中斷線程?Thread.sleep(1000);//?中斷線程?thread.interrupt();????}

看起來很通常的一個程序,但是事實卻并非你看到的樣子,其實這段代碼是會拋出InterruptedException異常的,我們來分析原因。

這里我們先要了解Thread.interrupt()方法不會中斷一個正在運行的線程,調(diào)用Thread.sleep()方法時,這個時候就不再占用CPU,我們來分析下我們這個程序,我們下載是要等待10秒,每次下載的速度是0.5M/S,也就是當(dāng)我們下載到5M的時候等待時間已經(jīng)到了,這個時候調(diào)用Thread.interrupt()方法中斷線程,但是run()方法中的睡眠還要接著往下執(zhí)行,它是不會因為中斷而放棄執(zhí)行下面的代碼的,那么這個時候當(dāng)它再執(zhí)行Thread.sleep()的時候就會拋出InterruptedException異常,因為當(dāng)前的線程已經(jīng)被中斷了。

說到這里,你是否已經(jīng)明白產(chǎn)生這個異常的原因了?另外還有另外的兩個原因致使線程產(chǎn)生InterruptedException異常的原因,wait()、join()兩個方法使用不當(dāng)也會引起線程拋出該異常。

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

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

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

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

1、具有1-5工作經(jīng)驗的,面對目前流行的技術(shù)不知從何下手,

需要突破技術(shù)瓶頸的可以加。

2、在公司待久了,過得很安逸,

但跳槽時面試碰壁。

需要在短時間內(nèi)進修、跳槽拿高薪的可以加。

3、如果沒有工作經(jīng)驗,但基礎(chǔ)非常扎實,對java工作機制,

常用設(shè)計思想,常用java開發(fā)框架掌握熟練的,可以加。

4、覺得自己很牛B,一般需求都能搞定。

但是所學(xué)的知識點沒有系統(tǒng)化,很難在技術(shù)領(lǐng)域繼續(xù)突破的可以加。

5. 群號:高級架構(gòu)群 Java進階群:180705916.備注好信息!送架構(gòu)視頻。

6.阿里Java高級大牛直播講解知識點,分享知識,

多年工作經(jīng)驗的梳理和總結(jié),帶著大家全面、

科學(xué)地建立自己的技術(shù)體系和技術(shù)認知!

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容