Java 中的線程中斷
- 1、什么是線程中斷
- 2、如何觸發線程中斷
- 3、如何處理線程中斷
- 3.1 線程中斷相關的核心方法
- 3.2 處理中斷的典型方式
- 3.3 注意事項
- 4、線程中斷與線程終止的區別
- 5、線程中斷的應用場景
- 5.1 長時間運行任務的取消
- 5.2 阻塞操作的快速響應
- 5.3 服務或線程池的優雅關閉
- 5.4 超時控制
- 5.5 事件驅動架構
- 6 線程中斷的常見問題
本篇文章將詳細介紹什么是線程中斷、如何觸發線程中斷、如何處理線程中斷、線程中斷與線程終止的區別 以及線程中斷的應用場景。
1、什么是線程中斷
Java線程中斷是一種線程間協作機制，用于通知線程應在合適的時候停止當前任務。中斷并非強制終止線程，而是通過設置線程的中斷標志位，由線程自身檢查并決定如何處理。
2、如何觸發線程中斷
-
使用
Thread.interrupt()方法
該方法向目標線程發送中斷信號，設置其中斷標志位為true。若線程處于阻塞狀態（如wait()、sleep()），會拋出InterruptedException并清除中斷標志。 -
如果任務通過線程池submit()方法提交到線程池中執行，可使用
Future.cancal(true)發送中斷信號
Future.cancal(true)會獲取到 阻塞在Future.get()的線程實例，然后調用thread.interrupt()方法。
3、如何處理線程中斷
3.1 線程中斷相關的核心方法
-
interrupt()
向目標線程發送中斷信號，設置其中斷標志位為true。若線程處于阻塞狀態（如wait()、sleep()），會拋出InterruptedException并清除中斷標志。 -
isInterrupted()
檢查線程的中斷標志位狀態，不會清除標志位。 -
Thread.interrupted()
靜態方法，檢查當前線程的中斷狀態并清除標志位（即重置為false）。
3.2 處理中斷的典型方式
響應中斷的阻塞操作
當線程調用如sleep()、wait()等方法時，需捕獲InterruptedException并恢復中斷狀態（避免吞沒中斷信號），因為 InterruptedException 會清除中斷狀態：
try {Thread.sleep(1000);
} catch (InterruptedException e) {Thread.currentThread().interrupt(); // 重新設置中斷標志// 執行清理或退出邏輯
}
主動檢查中斷狀態
通過循環中檢查isInterrupted()實現協作式終止：
while (!Thread.currentThread().isInterrupted()) {// 執行任務邏輯
}
3.3 注意事項
- 不可逆性：拋出
InterruptedException后中斷標志會被清除，需手動恢復。 - 非強制終止：線程可以忽略中斷，但通常不推薦。
- 資源清理：應在中斷處理中釋放資源（如關閉文件、網絡連接）。
4、線程中斷與線程終止的區別
- 線程中斷：是線程間協作機制，不強制終止線程的執行，依賴線程自身響應。
- 強制終止（已廢棄的
stop()）：直接終止線程，可能導致資源未釋放或數據不一致，不推薦使用。
5、線程中斷的應用場景
5.1 長時間運行任務的取消
當線程執行耗時操作（如I/O阻塞、復雜計算）時，外部可通過中斷信號請求終止任務。例如：
Thread worker = new Thread(() -> {while (!Thread.currentThread().isInterrupted()) { // 當收到中斷信號時退出循環// 執行任務邏輯}
});
worker.start();
worker.interrupt(); // 發起中斷請求
5.2 阻塞操作的快速響應
線程在Object.wait()、Thread.sleep()、或BlockingQueue.take()等阻塞方法時，調用interrupt()會拋出InterruptedException，立即終止等待狀態：
try {Thread.sleep(1000);
} catch (InterruptedException e) {Thread.currentThread().interrupt(); // 恢復中斷狀態// 清理資源
}
5.3 服務或線程池的優雅關閉
線程池通過中斷所有工作線程實現關閉。ExecutorService.shutdownNow()內部會遍歷線程并調用interrupt()，任務需檢查中斷狀態主動退出。
5.4 超時控制
結合Future.cancel(true)，可中斷正在執行的異步任務。若任務未響應中斷，超時后仍可能繼續占用資源。
5.5 事件驅動架構
在生產者-消費者模型中，中斷可用于緊急停止消費者線程。例如當系統內存不足時，中斷日志寫入線程避免OOM。
6 線程中斷的常見問題
為什么發送線程中斷后我的線程還在執行？
調用 interrupt 只是在線程中設置一個標記，并不會強制終止線程。如果線程執行的代碼邏輯中沒有 Thread.currentThread().isInterrupted() 或 Thread.interrupted() 的檢測邏輯和退出語句則線程執行不會受到任何影響。
為什么我無法檢測到線程中斷？
需要注意 拋出的 InterruptedException 異常和調用 Thread.interrupted() 會清除中斷狀態，之后判斷線程的中斷狀態則是 false。正確的做法是使用 Thread.currentThread().interrupt(); 重新設置中斷狀態，后續邏輯才能繼續判斷是否中斷。
