3. 线程中断机制的正确使用

中断机制的核心：标志位 + 阻塞唤醒

Java 的线程中断不是强制杀死线程，而是协作式的：interrupt() 设置目标线程的中断标志位；如果目标线程正阻塞在 sleep()、wait()、join()、BlockingQueue.take() 等可中断方法上，JVM 会抛出 InterruptedException 并清除中断标志位。理解“标志位是否被清除”是正确使用中断的关键。

可中断阻塞任务的完整实现

下面实现一个可中断的阻塞任务：工作线程循环从阻塞队列取任务，主线程在 2 秒后调用 interrupt()。通过日志观察 isInterrupted() 在阻塞前后的变化。

import java.util.concurrent.*;

public class InterruptDemo {
    public static void main(String[] args) throws Exception {
        BlockingQueue<String> queue = new LinkedBlockingQueue<>();
        Thread worker = new Thread(() -> {
            System.out.println("[Worker] 启动，准备阻塞在 take()");
            try {
                while (!Thread.currentThread().isInterrupted()) {
                    String task = queue.take(); // 可中断阻塞点
                    System.out.println("[Worker] 处理: " + task);
                }
            } catch (InterruptedException e) {
                System.out.println("[Worker] 捕获 InterruptedException");
                System.out.println("[Worker] 标志位 = "
                        + Thread.currentThread().isInterrupted()); // false
                Thread.currentThread().interrupt(); // 恢复标志位
                System.out.println("[Worker] 恢复后标志位 = "
                        + Thread.currentThread().isInterrupted()); // true
            }
            System.out.println("[Worker] 退出");
        }, "worker");

        worker.start();
        Thread.sleep(2000);
        System.out.println("[Main] 调用 interrupt()");
        worker.interrupt();
        worker.join();
        System.out.println("[Main] 结束");
    }
}

关键行为验证