Java中Thread.currentThread().interrupt()使用及线程中断执行逻辑问询

一、Thread.currentThread().interrupt() 到底怎么用？ #

先给你掰明白核心逻辑：interrupt() 不是直接“杀死”线程，它只是给线程打了个「中断标记」——相当于告诉线程：“嘿，你该停下来了”。至于线程要不要停、什么时候停，完全由咱们写的代码决定。

常见的使用场景分两种：

• 对付阻塞线程：如果线程正卡在 sleep()、wait()、join() 这些阻塞方法上，调用 interrupt() 会直接让它抛出 InterruptedException，跳出阻塞状态。这时候咱们可以在异常处理里做收尾工作，比如终止线程。
• 让非阻塞线程主动停止：如果线程一直在跑循环任务，咱们得在代码里定期检查 Thread.currentThread().isInterrupted() 这个标记。一旦发现标记为 true，就主动停止任务、清理资源，然后退出。

给你举个实用的例子：

Thread t = new Thread(() -> {
    while (!Thread.currentThread().isInterrupted()) {
        System.out.println("线程正在干活...");
        try {
            Thread.sleep(1000); // 模拟阻塞
        } catch (InterruptedException e) {
            // 注意：抛出InterruptedException后，中断标记会被清空，所以要重新标记
            Thread.currentThread().interrupt();
            System.out.println("收到中断信号，准备收尾");
        }
    }
});
t.start();

// 3秒后给线程发中断信号
Thread.sleep(3000);
t.interrupt();

二、你的代码问题分析+实现方案 #

先看你写的这段代码：

Thread t = new Thread(){ 
    public void run(){ 
        try { 
            if(Thread.currentThread().isInterrupted()) { 
                doSomeProcess(); // 这里的isInterrupted()是true吗？
                return; 
            } 
            // 否则执行runScript(); 
        } catch (Exception e) { 
            e.printStackTrace(); 
        } 
    } 
}; 
t.start();

先解答你的两个疑问 #

1. isInterrupted() 标志是否为true？：只有在调用 t.interrupt() 之后，线程才会把这个标记设为true。如果线程启动后很快就执行到了这个if判断，而你还没调用interrupt，那标记就是false，不会走doSomeProcess()。
2. 调用interrupt后会立即停止执行doSomeProcess()吗？：不会！因为你的run()方法只在开头检查了一次标记。如果线程已经执行过这个if判断（比如已经在跑runScript()了），后续再调用interrupt，线程根本不会回头再检查标记，自然不会触发doSomeProcess()。

怎么实现“调用interrupt后立即响应并执行doSomeProcess()”？ #

核心思路是让线程持续监听中断标记，或者在阻塞操作中响应中断，分两种情况给你方案：

场景1：线程在循环执行任务

如果你的线程是一直在循环跑任务，那就在每次循环前检查标记：

Thread t = new Thread(){ 
    public void run(){ 
        try { 
            while (!Thread.currentThread().isInterrupted()) {
                // 执行常规任务
                runScript();
            }
            // 一旦检测到中断标记，立即执行doSomeProcess()
            doSomeProcess();
        } catch (InterruptedException e) {
            // 如果runScript()里有阻塞操作（比如sleep），捕获异常后也要执行doSomeProcess()
            Thread.currentThread().interrupt(); // 重置标记，避免后续判断失效
            doSomeProcess();
        } catch (Exception e) { 
            e.printStackTrace(); 
        } 
    } 
}; 
t.start();

场景2：线程执行单次耗时任务

如果runScript()是一个单次的大任务，没法拆成循环，那就在runScript()内部定期检查标记：

private void runScript() throws InterruptedException {
    // 模拟耗时操作，每执行一小段就检查一次中断
    for (int i = 0; i < 1000; i++) {
        // 一检测到中断就抛出异常，回到run()方法执行doSomeProcess()
        if (Thread.currentThread().isInterrupted()) {
            throw new InterruptedException("线程被中断，停止当前操作");
        }
        // 执行具体的子任务
        doSubTask();
    }
}

这样一来，不管你在代码哪个位置调用t.interrupt()，线程都会在下次检查标记（或阻塞时被唤醒）时，立刻停止当前操作，转而执行doSomeProcess()。

内容的提问来源于stack exchange，提问作者Nasif Imtiaz Ohi