Java線程Thread之interrupt中斷的示例分析

這篇文章將為大家詳細(xì)講解有關(guān)Java線程Thread之interrupt中斷的示例分析，小編覺得挺實(shí)用的，因此分享給大家做個(gè)參考，希望大家閱讀完這篇文章后可以有所收獲。

成都創(chuàng)新互聯(lián)公司長(zhǎng)期為數(shù)千家客戶提供的網(wǎng)站建設(shè)服務(wù)，團(tuán)隊(duì)從業(yè)經(jīng)驗(yàn)10年，關(guān)注不同地域、不同群體，并針對(duì)不同對(duì)象提供差異化的產(chǎn)品和服務(wù)；打造開放共贏平臺(tái)，與合作伙伴共同營(yíng)造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為海鹽企業(yè)提供專業(yè)的做網(wǎng)站、成都網(wǎng)站設(shè)計(jì)，海鹽網(wǎng)站改版等技術(shù)服務(wù)。擁有十多年豐富建站經(jīng)驗(yàn)和眾多成功案例,為您定制開發(fā)。

中斷線程

線程的thread.interrupt()方法是中斷線程，將會(huì)設(shè)置該線程的中斷狀態(tài)位，即設(shè)置為true，中斷的結(jié)果線程是死亡、還是等待新的任務(wù)或是繼續(xù)運(yùn)行至下一步，就取決于這個(gè)程序本身。線程會(huì)不時(shí)地檢測(cè)這個(gè)中斷標(biāo)示位，以判斷線程是否應(yīng)該被中斷（中斷標(biāo)示值是否為true）。它并不像stop方法那樣會(huì)中斷一個(gè)正在運(yùn)行的線程。

判斷線程是否被中斷

判斷某個(gè)線程是否已被發(fā)送過中斷請(qǐng)求，請(qǐng)使用Thread.currentThread().isInterrupted()方法（因?yàn)樗鼘⒕€程中斷標(biāo)示位設(shè)置為true后，不會(huì)立刻清除中斷標(biāo)示位，即不會(huì)將中斷標(biāo)設(shè)置為false），而不要使用thread.interrupted()（該方法調(diào)用后會(huì)將中斷標(biāo)示位清除，即重新設(shè)置為false）方法來判斷，下面是線程在循環(huán)中時(shí)的中斷方式：

while(!Thread.currentThread().isInterrupted() && more work to do){
 do more work
}

interrupt之中斷狀態(tài)標(biāo)記

interrupt中斷機(jī)制中有如下方法：

1. Thread.interrupt()，設(shè)置當(dāng)前中斷標(biāo)記為true（類似屬性的set方法）

2. Thread.isInterrupted()，檢測(cè)當(dāng)前的中斷標(biāo)記（類似屬性的get方法）

3. Thread.interrupted()，檢測(cè)當(dāng)前的中斷標(biāo)記，然后重置中斷標(biāo)記為false（類似屬性的get方法+set方法）

因此interrupt中斷機(jī)制并不是真正的將當(dāng)前線程中斷，而是一個(gè)中斷標(biāo)記的變化。我們先用例子來測(cè)試一下。

public class InterruptTest {
 //這里用來打印消耗的時(shí)間
 private static long time = 0;
 private static void resetTime(){
 time = System.currentTimeMillis();
 }
 private static void printContent(String content){
 System.out.println(content + "  時(shí)間：" + (System.currentTimeMillis() - time));
 }

 public static void main(String[] args) {
 test1();
 }

 private static void test1(){
 Thread1 thread1 = new Thread1();
 thread1.start();
 //延時(shí)3秒后interrupt中斷
 try {
  Thread.sleep(3000);
 } catch (InterruptedException e) {
  e.printStackTrace();
 }
 thread1.interrupt();
 printContent("執(zhí)行中斷");
 }

 private static class Thread1 extends Thread{
 @Override public void run() {
  resetTime();
  int num = 0;
  while (true){
  if(isInterrupted()){
   printContent("當(dāng)前線程 isInterrupted");
   break;
  }
  num++;
  if(num % 100 == 0){
   printContent("num : " + num);
  }
  }
 }
 }
}

以上代碼是開啟一個(gè)Thread1線程，在Thread1線程的while循環(huán)中不斷對(duì)num加1，每到100的倍數(shù)打印一次（防止打印太快）。然后主線程在sleep了3000毫秒后，調(diào)用Thread1線程的interrupt方法。那么我們看看輸出結(jié)果：

intterupt中斷

可以看到，在耗時(shí)3000毫秒左右，也就是主線程sleep之后執(zhí)行thread1.interrupt();后，Thread1線程停止了，而Thread1線程的停止是因?yàn)閣hile循環(huán)中的isInterrupted方法返回了true，所以break退出了while循環(huán)，也就是說interrupt和isInterrupted在這里起到的作用就相當(dāng)于setXX和getXX的作用，維護(hù)著一個(gè)boolean變量。

interrupt之中斷異常處理

當(dāng)然interrupt機(jī)制并不僅僅是一個(gè)中斷狀態(tài)位的變化和檢測(cè)，它還可以進(jìn)行中斷異常的處理。我們知道Thread.sleep()方法需要捕獲中斷異常，那接下來我們往其中添加一個(gè)sleep延時(shí)試試

 while (true){
 if(isInterrupted()){
  printContent("當(dāng)前線程 isInterrupted");
  break;
 }
 num++; 
 //sleep一下
 try {
  Thread.sleep(1);
 } catch (InterruptedException e) {
  e.printStackTrace();
 }

 if(num % 100 == 0){
  printContent("num : " + num);
 }
 }

我們?cè)倏纯摧敵鼋Y(jié)果：

intterupt中斷

這里我們會(huì)發(fā)現(xiàn)，sleep睡眠之后，輸出的num值明顯小了好多（沒睡眠時(shí)num都達(dá)到10億的大小了，看來CPU執(zhí)行簡(jiǎn)單運(yùn)算還是非?？斓模?，哈哈，不過這不是重點(diǎn)，重點(diǎn)是是看到輸出了一個(gè)異常，還有就是輸出異常后，isInterrupted輸出返回false，Thread1線程又繼續(xù)執(zhí)行下去了，并沒有退出while循環(huán)。那么這是為什么呢？我們只是加了一個(gè)sleep睡眠而已。

如果Thread1線程中有執(zhí)行需要捕獲InterruptedException異常的操作，比如Thread的sleep，join方法，Object的wait，Condition的await等，它是強(qiáng)制需要捕獲InterruptedException異常的，那么當(dāng)thread1.interrupt方法調(diào)用之后，它會(huì)給thread1線程拋出一個(gè)InterruptedException異常，那么在while循環(huán)中，就能捕獲到這個(gè)異常然后這個(gè)異常拋出之后，又會(huì)馬上將線程中斷標(biāo)識(shí)重置為false，因此在下次的while循環(huán)中判斷isInterrupted時(shí)，它是false，也就不會(huì)break，然后while循環(huán)會(huì)一直執(zhí)行下去。

因此interrupt()方法會(huì)根據(jù)thread線程中的run方法里是否有必須捕獲InterruptedException異常的代碼，而做出不同操作：

1. 如果沒有必須捕獲InterruptedException異常的代碼(比如Thread.sleep())，則isInterrupted()會(huì)返回true，此時(shí)可以在isInterrupted的判斷中處理中斷變化。

2. 如果有必須捕獲InterruptedException異常的代碼(比如Thread.sleep())，則會(huì)拋出InterruptedException異常，并進(jìn)行捕獲，同時(shí)重置isInterrupted為false，此時(shí)得在異常捕獲中處理中斷變化。

interrupt的應(yīng)用場(chǎng)景

通常interrupt適用于在線程執(zhí)行中的循環(huán)標(biāo)記判斷，例如

while(!isInterrupted()){
 ...
}

但是如果在本次循環(huán)中出現(xiàn)阻塞了，那么線程就無法判斷下次的isInterrupted標(biāo)記，那么即便調(diào)用了interrupt()方法也無法退出循環(huán)，也就無法退出線程。例如

while(!isInterrupted()){
 ... 
 while(true){
  //線程卡在這里了，則無法響應(yīng)interrupte機(jī)制了
 }
}

這樣的話，interrupt就沒轍了，線程會(huì)一直執(zhí)行下去，不會(huì)被中斷停止。

關(guān)于“Java線程Thread之interrupt中斷的示例分析”這篇文章就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，使各位可以學(xué)到更多知識(shí)，如果覺得文章不錯(cuò)，請(qǐng)把它分享出去讓更多的人看到。

標(biāo)題名稱：Java線程Thread之interrupt中斷的示例分析
本文路徑：http://muchs.cn/article34/pjjjpe.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供企業(yè)網(wǎng)站制作、搜索引擎優(yōu)化、響應(yīng)式網(wǎng)站、網(wǎng)站設(shè)計(jì)、虛擬主機(jī)、服務(wù)器托管

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)