1. 引言

在多線程編程中，如何安全、優(yōu)雅地停止一個線程是一個經(jīng)典而又容易出錯的話題。Thread 類提供的 stop()、suspend() 等方法早已被廢棄，因為它們強行終止線程可能導(dǎo)致資源泄露或數(shù)據(jù)不一致。那么，正確的姿勢是什么？答案就是——協(xié)作式中斷機制。

本文將帶你深入理解 Java 的中斷模型，掌握 interrupt()、interrupted()、isInterrupted() 的區(qū)別與用法，并對比三種常見的停止線程方式：volatile 標(biāo)志位、AtomicBoolean 以及中斷機制。通過流程圖和代碼示例，幫你徹底掌握線程的優(yōu)雅關(guān)閉技巧。

2. 線程中斷機制核心概念

Java 中的中斷并不是真正“打斷”線程，而是設(shè)置一個中斷標(biāo)志位，由目標(biāo)線程自行檢查該標(biāo)志并決定如何響應(yīng)。這是一種協(xié)作式的取消機制。

2.1 中斷相關(guān)方法

2.2 中斷狀態(tài)流轉(zhuǎn)圖

2.3 阻塞方法的中斷響應(yīng)

當(dāng)線程處于 Object.wait()、Thread.sleep()、Thread.join() 等阻塞狀態(tài)時，調(diào)用 interrupt() 會立即拋出 InterruptedException，并清除中斷標(biāo)志。因此，在 catch 塊中如果需要保留中斷狀態(tài)，必須再次調(diào)用 interrupt()。

try {
    Thread.sleep(1000);
} catch (InterruptedException e) {
    // 重新設(shè)置中斷標(biāo)志，讓上層邏輯感知
    Thread.currentThread().interrupt();
    // 或者直接退出線程
    return;
}

3. 三種優(yōu)雅停止線程的方式

3.1 方式一：volatile 布爾標(biāo)志位

利用 volatile 保證內(nèi)存可見性，在循環(huán)中檢查標(biāo)志位，適合不涉及阻塞操作的場景。

public class VolatileStopDemo implements Runnable {
    private volatile boolean running = true;

    @Override
    public void run() {
        while (running) {
            // 執(zhí)行任務(wù)
        }
        System.out.println("線程結(jié)束");
    }

    public void stop() {
        running = false;
    }
}

優(yōu)點：簡單直觀。

缺點：若線程處于 sleep 或 wait 等阻塞狀態(tài)，無法立即響應(yīng)。

3.2 方式二：AtomicBoolean

與 volatile 類似，但提供原子性的 getAndSet 等操作，適合需要安全修改標(biāo)志的場景。

public class AtomicStopDemo implements Runnable {
    private AtomicBoolean running = new AtomicBoolean(true);

    @Override
    public void run() {
        while (running.get()) {
            // 執(zhí)行任務(wù)
        }
    }

    public void stop() {
        running.set(false);
    }
}

3.3 方式三：中斷標(biāo)志（推薦）

利用 interrupt() + 檢查 isInterrupted()，能夠同時響應(yīng)阻塞狀態(tài)和非阻塞狀態(tài)。

public class InterruptStopDemo implements Runnable {
    @Override
    public void run() {
        // 循環(huán)中檢查中斷標(biāo)志
        while (!Thread.currentThread().isInterrupted()) {
            try {
                // 可能阻塞的操作
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                // 收到中斷異常后，退出循環(huán)
                Thread.currentThread().interrupt(); // 重置標(biāo)志（可選）
                break;
            }
        }
        System.out.println("線程通過中斷停止");
    }

    public void stop() {
        Thread.currentThread().interrupt();
    }
}

4. 三種停止方式對比

5. 常見誤區(qū)與最佳實踐

誤區(qū)：interrupt()會立即終止線程

錯。它只是發(fā)了個“信號”，線程需要自己配合檢查才能停止。

誤區(qū)：捕獲InterruptedException后中斷標(biāo)志自動恢復(fù)

半對。異常被拋出時中斷標(biāo)志被清除，但你可以手動重置。

誤區(qū)：interrupted()和isInterrupted()一樣

錯。interrupted() 會清除標(biāo)志，而 isInterrupted() 不改變。

最佳實踐

• 在 Runnable 或 Thread 的 run() 方法中，始終通過 while(!isInterrupted()) 或 while(running) 循環(huán)執(zhí)行。
• 如果調(diào)用了可中斷的阻塞方法，一定要處理 InterruptedException，并在異常后重新設(shè)置中斷標(biāo)志或退出。
• 不要吞掉 InterruptedException（即 catch 后啥也不干），這會導(dǎo)致中斷信號丟失。
• 在封裝庫或框架時，優(yōu)先使用中斷機制而非自定義標(biāo)志，以便與 Java 并發(fā)工具類（如 ExecutorService 的 shutdownNow()）兼容。

6. 完整示例：線程池中的中斷處理

ExecutorService executor = Executors.newSingleThreadExecutor();
Future<?> future = executor.submit(() -> {
    while (!Thread.currentThread().isInterrupted()) {
        System.out.println("working...");
        try {
            Thread.sleep(500);
        } catch (InterruptedException e) {
            System.out.println("收到中斷，退出");
            Thread.currentThread().interrupt(); // 重置標(biāo)志
            break;
        }
    }
});

// 停止線程（兩種方式）
// 方式1：優(yōu)雅關(guān)閉（等待任務(wù)完成）
executor.shutdown();
// 方式2：立即中斷
executor.shutdownNow();   // 內(nèi)部會調(diào)用 interrupt()

7. 總結(jié)

• 中斷是 Java 推薦的線程停止協(xié)作機制，通過 interrupt() 設(shè)置標(biāo)志，線程自行檢查并退出。
• 三種停止方式各有適用場景，但中斷機制最通用，能同時處理阻塞和非阻塞代碼。
• 牢記 interrupted() 會清除中斷狀態(tài)，而 isInterrupted() 不會。
• 在處理 InterruptedException 時，要么退出線程，要么重新設(shè)置中斷標(biāo)志。

一句話總結(jié)：停止線程不是“暴力殺死”，而是“禮貌請退”。掌握中斷，讓你的多線程程序更加健壯、可維護。

到此這篇關(guān)于一文帶你徹底搞懂Java中線程的中斷與優(yōu)雅停止的文章就介紹到這了,更多相關(guān)Java線程中斷與停止內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評論