在Java中如何使用Thread.interrupt取消线程

P粉602998670 2025-10-14 00:00:00 次阅读

调用Thread.interrupt()设置中断标志，阻塞时抛出InterruptedException并清除标志，线程需检查中断状态或捕获异常以响应中断。示例中worker线程循环检测中断，sleep时被中断后重新设置中断状态并退出。关键点包括不忽略InterruptedException、重置中断状态、主动轮询isInterrupted()。注意interrupt不能强制终止运行中的线程，必须由线程协作实现取消。

在Java中，Thread.interrupt() 是一种协作式中断机制，用于请求线程停止当前工作。它不会强制终止线程，而是通过设置线程的中断状态来通知线程“应该中断”，由线程自身决定如何响应。

1. 中断的基本原理

调用 thread.interrupt() 会将目标线程的中断标志位设为 true。如果该线程正在阻塞（如 sleep、wait、join 等），则会抛出 InterruptedException，同时清除中断状态。线程需要定期检查中断状态并做出适当处理。

2. 如何正确使用 interrupt

以下是一个使用 interrupt 安全取消线程的示例：

public class InterruptExample {
    public static void main(String[] args) throws InterruptedException {
        Thread worker = new Thread(() -> {
            while (!Thread.currentThread().isInterrupted()) {
                try {
                    System.out.println("工作线程运行中...");
                    Thread.sleep(1000); // 模拟耗时操作
                } catch (InterruptedException e) {
                    System.out.println("线程被中断，准备退出");
                    Thread.currentThread().interrupt(); // 重新设置中断状态
                    break;
                }
            }
            System.out.println("线程已安全退出");
        });

        worker.start();
        Thread.sleep(3000);
        worker.interrupt(); // 发起中断请求
    }
}