如何在Java中切斷線程

如何在Java中切斷線程？很多新手對此不是很清楚，為了幫助大家解決這個(gè)難題，下面小編將為大家詳細(xì)講解，有這方面需求的人可以來學(xué)習(xí)下，希望你能有所收獲。

使用interrupt（）切斷線程

    當(dāng)一個(gè)線程運(yùn)行時(shí)，另一個(gè)線程可以調(diào)用對應(yīng)的Thread對象的interrupt（）方法來中斷它，該方法只是在目標(biāo)線程中設(shè)置一個(gè)標(biāo)志，表示它已經(jīng)被中斷，并立即返回。這里需要注意的是，如果只是單純的調(diào)用interrupt（）方法，線程并沒有實(shí)際被中斷，會繼續(xù)往下執(zhí)行。

    下面一段代碼演示了休眠線程的中斷:

public class SleepInterrupt extends Object implements Runnable{ 
 public void run(){ 
  try{ 
   System.out.println("in run() - about to sleep for 20 seconds"); 
   Thread.sleep(20000); 
   System.out.println("in run() - woke up"); 
  }catch(InterruptedException e){ 
   System.out.println("in run() - interrupted while sleeping"); 
   //處理完中斷異常后，返回到run（）方法人口， 
   //如果沒有return，線程不會實(shí)際被中斷，它會繼續(xù)打印下面的信息 
   return; 
  } 
  System.out.println("in run() - leaving normally"); 
 } 
 public static void main(String[] args) { 
  SleepInterrupt si = new SleepInterrupt(); 
  Thread t = new Thread(si); 
  t.start(); 
  //主線程休眠2秒，從而確保剛才啟動的線程有機(jī)會執(zhí)行一段時(shí)間 
  try { 
   Thread.sleep(2000); 
  }catch(InterruptedException e){ 
   e.printStackTrace(); 
  } 
  System.out.println("in main() - interrupting other thread"); 
  //中斷線程t 
  t.interrupt(); 
  System.out.println("in main() - leaving"); 
 } 
} 

    運(yùn)行結(jié)果如下：

     主線程啟動新線程后，自身休眠2秒鐘，允許新線程獲得運(yùn)行時(shí)間。新線程打印信息“about to sleep for 20 seconds”后，繼而休眠20秒鐘，大約2秒鐘后，main線程通知新線程中斷，那么新線程的20秒的休眠將被打斷，從而拋出InterruptException異常，執(zhí)行跳轉(zhuǎn)到catch塊，打印出“interrupted while sleeping”信息，并立即從run（）方法返回，然后消亡，而不會打印出catch塊后面的“l(fā)eaving normally”信息。 

   請注意：由于不確定的線程規(guī)劃，上圖運(yùn)行結(jié)果的后兩行可能順序相反，這取決于主線程和新線程哪個(gè)先消亡。但前兩行信息的順序必定如上圖所示。

    另外，如果將catch塊中的return語句注釋掉，則線程在拋出異常后，會繼續(xù)往下執(zhí)行，而不會被中斷，從而會打印出”leaving normally“信息。

待決中斷

    在上面的例子中，sleep（）方法的實(shí)現(xiàn)檢查到休眠線程被中斷，它會相當(dāng)友好地終止線程，并拋出InterruptedException異常。另外一種情況，如果線程在調(diào)用sleep（）方法前被中斷，那么該中斷稱為待決中斷，它會在剛調(diào)用sleep（）方法時(shí)，立即拋出InterruptedException異常。

    下面的代碼演示了待決中斷:

public class PendingInterrupt extends Object { 
 public static void main(String[] args){ 
  //如果輸入了參數(shù)，則在mian線程中中斷當(dāng)前線程（亦即main線程） 
  if( args.length > 0 ){ 
   Thread.currentThread().interrupt(); 
  } 
  //獲取當(dāng)前時(shí)間 
  long startTime = System.currentTimeMillis(); 
  try{ 
   Thread.sleep(2000); 
   System.out.println("was NOT interrupted"); 
  }catch(InterruptedException x){ 
   System.out.println("was interrupted"); 
  } 
  //計(jì)算中間代碼執(zhí)行的時(shí)間 
  System.out.println("elapsedTime=" + ( System.currentTimeMillis() - startTime)); 
 } 
} 

    如果PendingInterrupt不帶任何命令行參數(shù)，那么線程不會被中斷，最終輸出的時(shí)間差距應(yīng)該在2000附近（具體時(shí)間由系統(tǒng)決定，不精確），如果PendingInterrupt帶有命令行參數(shù)，則調(diào)用中斷當(dāng)前線程的代碼，但main線程仍然運(yùn)行，最終輸出的時(shí)間差距應(yīng)該遠(yuǎn)小于2000，因?yàn)榫€程尚未休眠，便被中斷，因此，一旦調(diào)用sleep（）方法，會立即打印出catch塊中的信息。執(zhí)行結(jié)果如下: 

    這種模式下，main線程中斷它自身。除了將中斷標(biāo)志（它是Thread的內(nèi)部標(biāo)志）設(shè)置為true外，沒有其他任何影響。線程被中斷了，但main線程仍然運(yùn)行，main線程繼續(xù)監(jiān)視實(shí)時(shí)時(shí)鐘，并進(jìn)入try塊，一旦調(diào)用sleep（）方法，它就會注意到待決中斷的存在，并拋出InterruptException。于是執(zhí)行跳轉(zhuǎn)到catch塊，并打印出線程被中斷的信息。最后，計(jì)算并打印出時(shí)間差。

使用isInterrupted（）方法判斷中斷狀態(tài)

   可以在Thread對象上調(diào)用isInterrupted（）方法來檢查任何線程的中斷狀態(tài)。這里需要注意：線程一旦被中斷，isInterrupted（）方法便會返回true，而一旦sleep（）方法拋出異常，它將清空中斷標(biāo)志，此時(shí)isInterrupted（）方法將返回false。

   下面的代碼演示了isInterrupted（）方法的使用：

public class InterruptCheck extends Object{ 
 public static void main(String[] args){ 
  Thread t = Thread.currentThread(); 
  System.out.println("Point A: t.isInterrupted()=" + t.isInterrupted()); 
  //待決中斷，中斷自身 
  t.interrupt(); 
  System.out.println("Point B: t.isInterrupted()=" + t.isInterrupted()); 
  System.out.println("Point C: t.isInterrupted()=" + t.isInterrupted()); 
  try{ 
   Thread.sleep(2000); 
   System.out.println("was NOT interrupted"); 
  }catch( InterruptedException x){ 
   System.out.println("was interrupted"); 
  } 
  //拋出異常后，會清除中斷標(biāo)志，這里會返回false 
  System.out.println("Point D: t.isInterrupted()=" + t.isInterrupted()); 
 } 
} 

    運(yùn)行結(jié)果如下：

使用Thread.interrupted（）方法判斷中斷狀態(tài)

    可以使用Thread.interrupted（）方法來檢查當(dāng)前線程的中斷狀態(tài)（并隱式重置為false）。又由于它是靜態(tài)方法，因此不能在特定的線程上使用，而只能報(bào)告調(diào)用它的線程的中斷狀態(tài)，如果線程被中斷，而且中斷狀態(tài)尚不清楚，那么，這個(gè)方法返回true。與isInterrupted（）不同，它將自動重置中斷狀態(tài)為false，第二次調(diào)用Thread.interrupted（）方法，總是返回false，除非中斷了線程。

    如下代碼演示了Thread.interrupted（）方法的使用：

public class InterruptReset extends Object { 
 public static void main(String[] args) { 
  System.out.println( 
   "Point X: Thread.interrupted()=" + Thread.interrupted()); 
  Thread.currentThread().interrupt(); 
  System.out.println( 
   "Point Y: Thread.interrupted()=" + Thread.interrupted()); 
  System.out.println( 
   "Point Z: Thread.interrupted()=" + Thread.interrupted()); 
 } 
} 

    運(yùn)行結(jié)果如下：

    從結(jié)果中可以看出，當(dāng)前線程中斷自身后，在Y點(diǎn)，中斷狀態(tài)為true，并由Thread.interrupted（）自動重置為false，那么下次調(diào)用該方法得到的結(jié)果便是false。

補(bǔ)充

    這里補(bǔ)充下yield和join方法的使用。

    join方法用線程對象調(diào)用，如果在一個(gè)線程A中調(diào)用另一個(gè)線程B的join方法，線程A將會等待線程B執(zhí)行完畢后再執(zhí)行。

    yield可以直接用Thread類調(diào)用，yield讓出CPU執(zhí)行權(quán)給同等級的線程，如果沒有相同級別的線程在等待CPU的執(zhí)行權(quán)，則該線程繼續(xù)執(zhí)行。

看完上述內(nèi)容是否對您有幫助呢？如果還想對相關(guān)知識有進(jìn)一步的了解或閱讀更多相關(guān)文章，請關(guān)注億速云行業(yè)資訊頻道，感謝您對億速云的支持。