在Java多線程編程中，正確且安全地停止線程是一項關鍵技能。簡單粗暴地“殺死”線程不僅可能導致數據不一致性，還可能引發各種難以預測的錯誤。 ...
引言
在Java多線程編程中，正確且安全地停止線程是一項關鍵技能。簡單粗暴地“殺死”線程不僅可能導致數據不一致性，還可能引發各種難以預測的錯誤。本文將探討幾種在Java中優雅地停止線程的方法，以確保程式的健壯性和可靠性。
使用標誌位（共用變數）停止線程
一種常見的做法是使用一個boolean類型的標誌位來控制線程的執行。線程在執行任務的過程中不斷檢查標誌位的狀態，當標誌位被設置為true時，線程停止執行任務，從而退出線程。
class StoppableThread extends Thread {
private volatile boolean isStopped = true;
@Override
public void run() {
while (isStopped) {
// 線程執行任務的代碼
}
// 清理資源併在檢查到退出標誌時退出
}
public void stopThread() {
// 在需要時設置標識=false，停止線程
isStopped = false;
}
}
這種方式簡單易用，它可以控制線程的停止時機，靈活性較高，適用於簡單的線程任務。但是如果任務執行時間過長或者任務中有阻塞操作，可能無法及時響應停止請求。並且這種方式的任務中需要周期性地檢查標誌位狀態，可能會影響性能。
使用Thread.stop()方法（已過時）
雖然Thread類提供了stop()方法用於停止線程，但是這個方法已經被標記為過時(deprecated)，不推薦使用。因為它可能會導致線程不安全的終止，引發一系列問題，如不釋放鎖、資源泄露等。
stop()方法確實可以停止線程的。
使用interrupt()方法
Java提供了一種基於中斷模型的方式來請求線程停止。中斷並不是立即停止線程的運行，而是設置一個中斷標誌，線程需要自行檢查並響應這個中斷信號。
public static void main(String[] args) {
// 預設情況下，interrupted標記位為false。該方法用於檢查當前線程的中斷狀態，返回true表示線程已被中斷，返回false表示線程未被中斷
System.out.println("初始狀態下的Interrupted標記位：" + Thread.currentThread().isInterrupted());
// 執行Interrupted。該方法用於中斷當前線程，它會設置當前線程的中斷標記位為true。
Thread.currentThread().interrupt();
System.out.println("執行Interrupted後的Interrupted標記位：" + Thread.currentThread().isInterrupted());
// 該方法用於檢查當前線程的中斷狀態，並清除中斷狀態。如果當前線程被中斷，則返回true，並清除中斷狀態；如果當前線程未被中斷，則返回false。
System.out.println("返回當前線程：" + Thread.interrupted());
System.out.println(Thread.interrupted());
}
初始狀態下的Interrupted標記位：false
執行Interrupted後的Interrupted標記位：true
返回當前線程：true
false
在這段代碼中，兩次調用interrupted()方法，第一次返回true（因為之前調用了interrupt()方法），第二次返回false（因為在第一次調用後，中斷狀態被清除）。
Thread myThread = new Thread(() -> {
while (!Thread.currentThread().isInterrupted()) {
// 執行任務...
}
// 清理資源併在檢查到中斷標誌時退出
});
myThread.start();
// 在需要停止線程時
myThread.interrupt();
對於阻塞操作（如IO操作或wait()方法），當線程在阻塞狀態時收到中斷請求，某些方法會拋出InterruptedException。在這種情況下，處理方式通常是捕獲異常，執行必要的清理操作，並根據需要決定是否退出線程。
try {
synchronized (someLock) {
someLock.wait(); // 在wait期間，如果線程被中斷，會拋出InterruptedException
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt(); // 重新設置中斷標誌，以便後續代碼可以感知
// 清理並退出線程
}
這種方式可以優雅地停止線程，即使線程處於阻塞狀態也能夠及時響應停止請求。通過捕獲InterruptedException異常，可以在停止線程時進行清理工作。但是需要線上程任務中處理InterruptedException異常，這無形之中增加了代碼複雜度。並且如果任務不是阻塞的，需要在任務中周期性地檢查線程的中斷狀態。
使用線程池來管理線程
使用ExecutorService來管理線程可以更加靈活地控制線程的生命周期。通過調用ExecutorService的shutdown()或shutdownNow()方法來停止線程池中的所有線程，從而優雅地停止線程。
ExecutorService executor = Executors.newFixedThreadPool(5);
// 提交任務到線程池
executor.submit(new MyTask());
// 關閉線程池
executor.shutdown();
通過ExecutorService可以更加靈活地管理線程，包括啟動、執行和停止。但是他是停止線程池中的所有線程。在Java中，沒有直接提供停止線程池中特定線程的方法。因為線程池是一種管理線程的容器，它負責管理線程的創建、調度和銷毀。但是我們可以使用Future對象來表示線程池中的任務，通過調用Future的cancel(boolean mayInterruptIfRunning)方法，可以嘗試取消任務的執行。在調用cancel(true)時，表示可以中斷正在運行的任務。
ExecutorService executor = Executors.newSingleThreadExecutor();
Future<?> future = executor.submit(() -> {
// 執行任務...
// 在適當位置檢查Thread.currentThread().isInterrupted()
});
// 在需要停止任務時
future.cancel(true); // 參數為true表示可以中斷正在運行的任務
executor.shutdown();
這種方式雖然調用了cancel(true)，任務也需要在適當的時機檢查中斷狀態並做出相應處理。如果任務已經被中斷，可能無法繼續執行，需要在任務中捕獲InterruptedException異常併進行適當的清理工作。
總結
優雅地停止線程是編寫高質量Java多線程程式的關鍵之一。在選擇停止線程的方法時，需要考慮線程的執行情況、任務特性以及程式設計的要求。一般而言，使用interrupt()方法或者ExecutorService來管理線程是較為推薦的做法，可以有效地避免線程不安全的終止以及資源泄露等問題。
本文已收錄於我的個人博客：碼農Academy的博客，專註分享Java技術乾貨，包括Java基礎、Spring Boot、Spring Cloud、Mysql、Redis、Elasticsearch、中間件、架構設計、面試題、程式員攻略等
