出自
> [Java并發編程(2):線程中斷(含代碼)](http://www.importnew.com/20527.html)
[TOC=1,2]
原文出處:?[蘭亭風雨](http://blog.csdn.net/ns_code/article/details/17091267)
# 使用interrupt()中斷線程
當一個線程運行時,另一個線程可以調用對應的Thread對象的interrupt()方法來中斷它,該方法只是在目標線程中設置一個標志,表示它已經被中斷,并立即返回。這里需要注意的是,如果只是單純的調用interrupt()方法,線程并沒有實際被中斷,會繼續往下執行。
下面一段代碼演示了休眠線程的中斷:
~~~
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,線程不會實際被中斷,它會繼續打印下面的信息
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秒,從而確保剛才啟動的線程有機會執行一段時間
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");
}
}
~~~
運行結果如下:

? ? ?主線程啟動新線程后,自身休眠2秒鐘,允許新線程獲得運行時間。新線程打印信息“about to sleep for 20 seconds”后,繼而休眠20秒鐘,大約2秒鐘后,main線程通知新線程中斷,那么新線程的20秒的休眠將被打斷,從而拋出InterruptException異常,執行跳轉到catch塊,打印出“interrupted while sleeping”信息,并立即從run()方法返回,然后消亡,而不會打印出catch塊后面的“leaving normally”信息。
? ??請注意:由于不確定的線程規劃,上圖運行結果的后兩行可能順序相反,這取決于主線程和新線程哪個先消亡。但前兩行信息的順序必定如上圖所示。
? ? 另外,如果將catch塊中的return語句注釋掉,則線程在拋出異常后,會繼續往下執行,而不會被中斷,從而會打印出”leaving normally“信息。
# 待決中斷
在上面的例子中,sleep()方法的實現檢查到休眠線程被中斷,它會相當友好地終止線程,并拋出InterruptedException異常。另外一種情況,如果線程在調用sleep()方法前被中斷,那么該中斷稱為待決中斷,它會在剛調用sleep()方法時,立即拋出InterruptedException異常。
下面的代碼演示了待決中斷:
~~~
public class PendingInterrupt extends Object {
public static void main(String[] args){
//如果輸入了參數,則在mian線程中中斷當前線程(亦即main線程)
if( args.length > 0 ){
Thread.currentThread().interrupt();
}
//獲取當前時間
long startTime = System.currentTimeMillis();
try{
Thread.sleep(2000);
System.out.println("was NOT interrupted");
}catch(InterruptedException x){
System.out.println("was interrupted");
}
//計算中間代碼執行的時間
System.out.println("elapsedTime=" + ( System.currentTimeMillis() - startTime));
}
}
~~~
如果PendingInterrupt不帶任何命令行參數,那么線程不會被中斷,最終輸出的時間差距應該在2000附近(具體時間由系統決定,不精確),如果PendingInterrupt帶有命令行參數,則調用中斷當前線程的代碼,但main線程仍然運行,最終輸出的時間差距應該遠小于2000,因為線程尚未休眠,便被中斷,因此,一旦調用sleep()方法,會立即打印出catch塊中的信息。執行結果如下:

? ? 這種模式下,main線程中斷它自身。除了將中斷標志(它是Thread的內部標志)設置為true外,沒有其他任何影響。線程被中斷了,但main線程仍然運行,main線程繼續監視實時時鐘,并進入try塊,一旦調用sleep()方法,它就會注意到待決中斷的存在,并拋出InterruptException。于是執行跳轉到catch塊,并打印出線程被中斷的信息。最后,計算并打印出時間差。
# 使用isInterrupted()方法判斷中斷狀態
? ?可以在Thread對象上調用isInterrupted()方法來檢查任何線程的中斷狀態。這里需要注意:線程一旦被中斷,isInterrupted()方法便會返回true,而一旦sleep()方法拋出異常,它將清空中斷標志,此時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");
}
//拋出異常后,會清除中斷標志,這里會返回false
System.out.println("Point D: t.isInterrupted()=" + t.isInterrupted());
}
}
~~~
運行結果如下:

# 使用Thread.interrupted()方法判斷中斷狀態
可以使用Thread.interrupted()方法來檢查當前線程的中斷狀態(并隱式重置為false)。又由于它是靜態方法,因此不能在特定的線程上使用,而只能報告調用它的線程的中斷狀態,如果線程被中斷,而且中斷狀態尚不清楚,那么,這個方法返回true。與isInterrupted()不同,它將自動重置中斷狀態為false,第二次調用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點,中斷狀態為true,并由Thread.interrupted()自動重置為false,那么下次調用該方法得到的結果便是false。
# 補充
? ? 這里補充下yield和join方法的使用。
? ? join方法用線程對象調用,如果在一個線程A中調用另一個線程B的join方法,線程A將會等待線程B執行完畢后再執行。
? ? yield可以直接用Thread類調用,yield讓出CPU執行權給同等級的線程,如果沒有相同級別的線程在等待CPU的執行權,則該線程繼續執行。
- JVM
- 深入理解Java內存模型
- 深入理解Java內存模型(一)——基礎
- 深入理解Java內存模型(二)——重排序
- 深入理解Java內存模型(三)——順序一致性
- 深入理解Java內存模型(四)——volatile
- 深入理解Java內存模型(五)——鎖
- 深入理解Java內存模型(六)——final
- 深入理解Java內存模型(七)——總結
- Java內存模型
- Java內存模型2
- 堆內內存還是堆外內存?
- JVM內存配置詳解
- Java內存分配全面淺析
- 深入Java核心 Java內存分配原理精講
- jvm常量池
- JVM調優總結
- JVM調優總結(一)-- 一些概念
- JVM調優總結(二)-一些概念
- VM調優總結(三)-基本垃圾回收算法
- JVM調優總結(四)-垃圾回收面臨的問題
- JVM調優總結(五)-分代垃圾回收詳述1
- JVM調優總結(六)-分代垃圾回收詳述2
- JVM調優總結(七)-典型配置舉例1
- JVM調優總結(八)-典型配置舉例2
- JVM調優總結(九)-新一代的垃圾回收算法
- JVM調優總結(十)-調優方法
- 基礎
- Java 征途:行者的地圖
- Java程序員應該知道的10個面向對象理論
- Java泛型總結
- 序列化與反序列化
- 通過反編譯深入理解Java String及intern
- android 加固防止反編譯-重新打包
- volatile
- 正確使用 Volatile 變量
- 異常
- 深入理解java異常處理機制
- Java異常處理的10個最佳實踐
- Java異常處理手冊和最佳實踐
- Java提高篇——對象克隆(復制)
- Java中如何克隆集合——ArrayList和HashSet深拷貝
- Java中hashCode的作用
- Java提高篇之hashCode
- 常見正則表達式
- 類
- 理解java類加載器以及ClassLoader類
- 深入探討 Java 類加載器
- 類加載器的工作原理
- java反射
- 集合
- HashMap的工作原理
- ConcurrentHashMap之實現細節
- java.util.concurrent 之ConcurrentHashMap 源碼分析
- HashMap的實現原理和底層數據結構
- 線程
- 關于Java并發編程的總結和思考
- 40個Java多線程問題總結
- Java中的多線程你只要看這一篇就夠了
- Java多線程干貨系列(1):Java多線程基礎
- Java非阻塞算法簡介
- Java并發的四種風味:Thread、Executor、ForkJoin和Actor
- Java中不同的并發實現的性能比較
- JAVA CAS原理深度分析
- 多個線程之間共享數據的方式
- Java并發編程
- Java并發編程(1):可重入內置鎖
- Java并發編程(2):線程中斷(含代碼)
- Java并發編程(3):線程掛起、恢復與終止的正確方法(含代碼)
- Java并發編程(4):守護線程與線程阻塞的四種情況
- Java并發編程(5):volatile變量修飾符—意料之外的問題(含代碼)
- Java并發編程(6):Runnable和Thread實現多線程的區別(含代碼)
- Java并發編程(7):使用synchronized獲取互斥鎖的幾點說明
- Java并發編程(8):多線程環境中安全使用集合API(含代碼)
- Java并發編程(9):死鎖(含代碼)
- Java并發編程(10):使用wait/notify/notifyAll實現線程間通信的幾點重要說明
- java并發編程-II
- Java多線程基礎:進程和線程之由來
- Java并發編程:如何創建線程?
- Java并發編程:Thread類的使用
- Java并發編程:synchronized
- Java并發編程:Lock
- Java并發編程:volatile關鍵字解析
- Java并發編程:深入剖析ThreadLocal
- Java并發編程:CountDownLatch、CyclicBarrier和Semaphore
- Java并發編程:線程間協作的兩種方式:wait、notify、notifyAll和Condition
- Synchronized與Lock
- JVM底層又是如何實現synchronized的
- Java synchronized詳解
- synchronized 與 Lock 的那點事
- 深入研究 Java Synchronize 和 Lock 的區別與用法
- JAVA編程中的鎖機制詳解
- Java中的鎖
- TreadLocal
- 深入JDK源碼之ThreadLocal類
- 聊一聊ThreadLocal
- ThreadLocal
- ThreadLocal的內存泄露
- 多線程設計模式
- Java多線程編程中Future模式的詳解
- 原子操作(CAS)
- [譯]Java中Wait、Sleep和Yield方法的區別
- 線程池
- 如何合理地估算線程池大小?
- JAVA線程池中隊列與池大小的關系
- Java四種線程池的使用
- 深入理解Java之線程池
- java并發編程III
- Java 8并發工具包漫游指南
- 聊聊并發
- 聊聊并發(一)——深入分析Volatile的實現原理
- 聊聊并發(二)——Java SE1.6中的Synchronized
- 文件
- 網絡
- index
- 內存文章索引
- 基礎文章索引
- 線程文章索引
- 網絡文章索引
- IOC
- 設計模式文章索引
- 面試
- Java常量池詳解之一道比較蛋疼的面試題
- 近5年133個Java面試問題列表
- Java工程師成神之路
- Java字符串問題Top10
- 設計模式
- Java:單例模式的七種寫法
- Java 利用枚舉實現單例模式
- 常用jar
- HttpClient和HtmlUnit的比較總結
- IO
- NIO
- NIO入門
- 注解
- Java Annotation認知(包括框架圖、詳細介紹、示例說明)