您现在的位置：程式碼之家 >> 編程語言 > >> Java 程式設計 >> Java 綜合教學

Java 線程優雅終止指南：拒絕 stop()，掌握中斷模式與 volatile 可見性

編輯：Java 綜合教學

Java 線程優雅終止指南：拒絕 stop()，掌握中斷模式與 volatile 可見性

Thread.stop()、suspend()、resume() 自 JDK 1.2 起被棄用，因其強制釋放鎖導致數據不一致。本文詳解標準的「標誌位 + 中斷」優雅終止模式，並分析 volatile 關鍵字對可見性的保證。

為什麼不能用 stop()？

強制殺死線程，釋放所有持有的鎖
被保護的數據可能處於不一致狀態（如轉賬扣款成功、存款失敗）
無法執行 finally 清理資源（關閉連接、釋放文件句柄）

標準優雅終止模式

public class GracefulShutdownThread extends Thread {
    // volatile 保證：主線程修改對工作線程立即可見，禁止指令重排
    private volatile boolean running = true;

    @Override
    public void run() {
        while (running) {
            try {
                // 模擬業務邏輯
                doWork();
                // 可中斷阻塞，響應 interrupt()
                Thread.sleep(5000); 
            } catch (InterruptedException e) {
                // 關鍵：睡眠被中斷，異常中清除中斷狀態
                // 此處應退出循環，而非繼續
                Thread.currentThread().interrupt(); // 可選：恢復中斷狀態供上層感知
                break; // 或 return 直接結束 run()
            }
        }
        // 清理資源
        cleanup();
    }

    // 對外提供的安全停止入口
    public void shutdown() {
        running = false;      // 1. 設置標誌位（非阻塞場景生效）
        interrupt();          // 2. 中斷阻塞（睡眠/IO/鎖等待）
    }

    private void doWork() { /* 業務邏輯 */ }
    private void cleanup() { /* 關閉連接、釋放鎖等 */ }
}

關鍵點深度解析

1. volatile 的雙重保障

可見性：主線程寫 running = false，工作線程下次讀取必見新值
有序性：禁止編譯器/JIT 將 running = false 重排到其他操作之後

無 volatile 時，JIT 可能將循環優化為 if (running) while(true) ... 導致永不退出。

2. 中斷機制 InterruptedException

sleep()、wait()、join()、Channel 操作等阻塞方法會拋出 InterruptedException
異常拋出前，JVM 自動清除中斷標誌
捕獲異常後，必須決定：退出線程或恢復中斷標誌

catch (InterruptedException e) {
    // 方案 A：直接退出（最常見）
    break; 
    
    // 方案 B：恢復標誌，讓上層調用者感知（若 run() 不直接結束）
    Thread.currentThread().interrupt(); 
}

3. 非阻塞場景：輪詢標誌位

while (running && !currentThread().isInterrupted()) {
    // 計算密集型任務，無阻塞調用
    heavyCompute();
    // 定期主動檢查中斷標誌
    if (currentThread().isInterrupted()) break;
}

完整使用示例

public static void main(String[] args) throws InterruptedException {
    GracefulShutdownThread worker = new GracefulShutdownThread();
    worker.start();
    
    // 主線程做其他事...
    Thread.sleep(10000);
    
    // 發起優雅關閉
    worker.shutdown();
    
    // 等待線程真正結束（可設超時）
    worker.join(5000); 
    
    if (worker.isAlive()) {
        System.err.println("警告：線程未在5秒內結束，可能卡死");
    } else {
        System.out.println("線程已優雅退出");
    }
}

進階：ExecutorService 關閉模式

ExecutorService executor = Executors.newFixedThreadPool(10);
// 提交任務...
executor.shutdown(); // 拒絕新任務，等待現有任務完成
try {
    if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
        executor.shutdownNow(); // 強制中斷執行中任務
        if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
            System.err.println("線程池未能正常關閉");
        }
    }
} catch (InterruptedException e) {
    executor.shutdownNow();
    Thread.currentThread().interrupt();
}