如何在Java中处理线程中断Interrupt

答案是Java线程中断采用协作式设计，通过interrupt()设置中断标志或抛出InterruptedException，线程需主动检查状态并安全退出，避免强制终止导致的数据不一致或资源泄露，适用于任务取消、优雅关闭等场景，且捕获InterruptedException后应重新中断以传递信号。

在Java里处理线程中断，核心思想是“协作式”的。它不像一个强制的“杀手锏”，直接把线程干掉，而是给线程发一个信号，告诉它“你该停下来了”。线程收到这个信号后，需要自己去检查并决定如何优雅地退出，或者处理这个中断。这是一种更安全、更可控的线程终止机制。

解决方案

要有效地处理Java中的线程中断，我们需要理解中断信号是如何传递的，以及线程如何响应。这主要涉及两个方面：显式检查中断状态和处理

InterruptedException

当一个线程的

interrupt()

true

1. 显式检查中断状态

立即学习“Java免费学习笔记（深入）”；

在线程的运行逻辑中，尤其是长循环或者执行耗时操作时，我们应该周期性地检查这个中断状态。

• Thread.currentThread().isInterrupted()

  : 这是一个实例方法，它会检查当前线程的中断状态，并返回

  true

  或

  false

  ，但不会清除中断状态。这意味着你可以多次检查而不会丢失中断信号。

• Thread.interrupted()

  : 这是一个静态方法，它也会检查当前线程的中断状态。但关键在于，它在返回中断状态后，会清除当前线程的中断状态（将其设置为

  false

  ）。通常，这个方法在线程内部处理完中断后，需要重置状态时使用。

示例代码：

public class InterruptibleTask implements Runnable {
    @Override
    public void run() {
        while (!Thread.currentThread().isInterrupted()) {
            // 执行一些工作
            System.out.println(Thread.currentThread().getName() + " 正在执行任务...");
            try {
                // 模拟耗时操作，或者在阻塞方法中等待
                Thread.sleep(1000); 
            } catch (InterruptedException e) {
                System.out.println(Thread.currentThread().getName() + " 被中断了，准备退出。");
                // 收到InterruptedException时，中断状态会被清除
                // 重新设置中断状态，以便上层调用者或其他逻辑可以感知到中断
                Thread.currentThread().interrupt(); 
                break; // 退出循环
            }
        }
        System.out.println(Thread.currentThread().getName() + " 任务结束。");
    }
}

// 在主线程中启动和中断
public class Main {
    public static void main(String[] args) throws InterruptedException {
        Thread taskThread = new Thread(new InterruptibleTask(), "Worker-Thread");
        taskThread.start();

        Thread.sleep(3000); // 让任务执行一段时间
        taskThread.interrupt(); // 发送中断信号
        taskThread.join(); // 等待线程终止
        System.out.println("主线程结束。");
    }
}

2. 处理

InterruptedException

当线程执行一些阻塞操作，比如

Thread.sleep()

Object.wait()

Thread.join()

BlockingQueue.take()

Lock.lockInterruptibly()

Selector.select()

InterruptedException

一个非常重要的细节是：当

InterruptedException

false

最佳实践： 在捕获

InterruptedException

Thread.currentThread().interrupt();

eoeAndroid特刊第二期 Android图像处理篇 pdf版

eoeAndroid特刊第二期：Android图像处理篇 pdf，eoeAndroid策划的第二篇专题，主要整理和翻译在Android中进行图像处理的一些资源和文章，通过本专题内容的学习，您可以掌握如何在Android上对图片编程，主要包括但不限于如下方向的内容: 　　• Android中支持的图片格式介绍； 　　• Android中图片库介绍 　　• 图片的显示（本地的，网络的）； 　　• 图片的格式转换； 　　•

下载

为什么Java的线程中断不是强制性的？它有什么设计哲学？

这其实是Java并发设计里一个非常核心，也经常让人感到困惑的地方。为什么

Thread.interrupt()

Thread.stop()

设计成协作式的，而非强制性的，主要是出于安全性和健壮性的考量。你可以想象一下，如果一个线程正在执行一个关键的、需要保持数据一致性的操作，比如修改一个共享数据结构，或者正在进行数据库事务。如果此时你强制中断它，它可能在任何一个不确定的点被终止，导致：

1. 资源泄露： 线程可能没有机会关闭文件句柄、网络连接、数据库连接等资源。
2. 数据不一致： 共享数据结构可能处于部分修改的状态，导致其他线程读取到错误的数据。
3. 死锁： 线程可能在持有锁的情况下被终止，导致这些锁永远无法释放，其他线程因此而死锁。

Thread.stop()

interrupt()

在哪些场景下，我们应该使用线程中断，而不是其他终止线程的方法？

线程中断机制是Java中终止线程的首选和推荐方式，几乎在所有需要优雅地停止一个正在运行的线程的场景中都应该使用它。

• 长时间运行的任务取消： 比如一个后台数据处理任务、一个文件下载任务、一个复杂的计算任务。用户可能在任务进行到一半时决定取消。此时，通过中断信号通知任务停止，让它有机会保存进度、清理临时文件，而不是突然崩溃。
• 服务或应用程序的优雅关闭： 当一个Java应用或服务需要关闭时，通常会有一些后台线程（如消息消费者、定时任务执行者、网络连接监听器）在运行。通过中断这些线程，可以确保它们在退出前完成当前正在处理的工作，并释放所有占用的资源。
• 超时机制的实现： 有时我们希望某个操作在一定时间内完成，如果超时，就取消这个操作。例如，一个线程在等待某个事件发生，如果等待时间过长，可以中断它，让它停止等待并返回一个超时错误。
• 替代废弃的

  Thread.stop()

  ： 任何你曾经考虑使用

  Thread.stop()

  的场景，都应该转而使用线程中断。

  stop()

  方法由于其固有的不安全性，已经被废弃，并且不应该在任何新代码中使用。
• 避免使用简单的布尔标志： 虽然有时可以通过设置一个布尔变量来控制循环的终止，但这种方式无法处理线程阻塞在

  sleep()

  ,

  wait()

  ,

  join()

  等方法上的情况。中断机制能够优雅地“唤醒”这些阻塞的线程，并抛出

  InterruptedException

  ，提供统一的退出机制。

简而言之，只要你需要一个线程在完成当前工作后，或者在等待某个事件时，能够有机会进行清理并安全退出，那么线程中断就是最合适的工具。它提供了一种既灵活又安全的线程终止方式。

处理InterruptedException时，重新中断（re-interrupt）有什么重要性？

这是个非常关键的点，也是很多Java开发者容易犯错的地方。当一个方法抛出

InterruptedException

Thread.sleep(long millis)

catch (InterruptedException e)

想象一下这个场景： 你的代码A调用了代码B，代码B又调用了代码C。

• 代码C里面有个

  Thread.sleep(1000)

  。
• 外部某个地方调用了线程的

  interrupt()

  方法。

• sleep()

  方法抛出

  InterruptedException

  。
• 代码C捕获了这个异常，但只是简单地打印了堆栈信息，然后继续执行，或者直接返回了。

问题来了：当代码C返回后，代码B和代码A并不知道中断曾经发生过。线程的中断状态现在是

false

while (!Thread.currentThread().isInterrupted())

重新中断（

Thread.currentThread().interrupt();

InterruptedException

true

为什么这很重要？

1. 保持中断的协作性： 确保中断信号不会被无意中“吞噬”，维护了Java中断机制的协作性。
2. 避免意外行为： 如果不重新中断，线程可能会在应该停止的时候继续运行，导致资源浪费或逻辑错误。
3. 简化上层代码： 上层调用者不需要关心下层方法是否会清除中断状态，只需要统一检查

   isInterrupted()

   即可。
4. 遵循最佳实践： 这是Java并发编程中公认的最佳实践，有助于编写更健壮、更易于理解和维护的并发代码。

所以，除非你非常确定当前方法是中断的终点，并且已经完成了所有中断相关的清理工作，否则在捕获

InterruptedException