本文目录导读：
线程中断是 Java 并发编程中一个非常重要的概念，很多开发者对它的理解停留在“调用 interrupt() 方法就是让线程停止”的层面，但实际上，中断只是一种协作机制，它并不会强制停止线程，而是向线程发送一个“请停止你正在做的事情”的信号。
正确处理线程中断的核心原则是：被中断的线程拥有决定如何响应中断的主动权。
下面从原理、常见处理模式、陷阱到最佳实践，系统地讲解如何正确处理线程中断。
理解中断的本质（原理）
在 Java 中，每个线程都有一个 interrupted 标志位（布尔值）。
thread.interrupt()：将目标线程的中断标志位设置为true。Thread.interrupted()：静态方法，测试当前线程是否被中断，并清除中断标志位（重置为false）。thread.isInterrupted()：实例方法，测试线程是否被中断，不清除标志位。
关键： interrupt() 只是设置了一个标志位，如果线程因为 wait(), join(), sleep() 等方法而阻塞，调用 interrupt() 会抛出 InterruptedException。
正确处理中断的两种核心模式
根据你的代码是“主动执行任务”还是“调用会抛出 InterruptedException 的方法”，处理方式不同。
传递中断（推荐，最规范）
适用场景：你的方法是一个可被中断的库方法，或者你希望上层调用者来决定如何处理中断。
做法：在 catch (InterruptedException e) 块中，不吞掉异常，而是将中断信号继续向上传递。
有两种传递方式：
方式 A：再次声明抛出 InterruptedException
// 你的方法也声明抛出 InterruptedException
public void myTask() throws InterruptedException {
// 这里调用了会抛出 InterruptedException 的方法
Thread.sleep(10000);
// 或者
// someBlockingQueue.take();
}
方式 B：恢复中断状态（如果无法声明抛出）
如果你不能修改方法签名（例如实现了 Runnable 接口的 run() 方法，或者一个不抛出受检异常的接口），则必须在捕获异常后，重新调用 Thread.currentThread().interrupt()，恢复中断状态，以便上层代码能感知到。
public class MyTask implements Runnable {
@Override
public void run() {
try {
// 执行可能被中断的任务
while (true) {
// 一些工作
Thread.sleep(1000);
}
} catch (InterruptedException e) {
// 重新设置中断标志位
Thread.currentThread().interrupt();
// 这里可以做一些清理工作，然后退出循环
System.out.println("线程被中断，执行清理并退出");
}
}
}
立即响应（检查中断标志位）
适用场景：你自己的代码需要处理耗时任务（如循环），主动检查中断信号。
做法：在循环条件中或关键步骤中检查 Thread.currentThread().isInterrupted()，如果为 true，则进行清理并返回/退出。
public void doHeavyWork() {
while (true) {
// 1. 检查中断信号
if (Thread.currentThread().isInterrupted()) {
// 2. 清理资源
System.out.println("收到中断信号，正在清理...");
// 3. 退出
return;
}
// 4. 执行实际工作
// 这里可能会调用一些阻塞方法，如果也抛出 InterruptedException，需要配合处理
}
}
更完整的混合示例：
public void runTask() {
try {
while (!Thread.currentThread().isInterrupted()) {
// 执行一些工作
// 可能会执行阻塞 I/O 操作
someBlockingCall();
}
} catch (InterruptedException e) {
// 注意：当阻塞调用抛出 InterruptedException 时，中断标志位会被清除
// 所以通常需要在这里恢复标志位，或者直接 return
Thread.currentThread().interrupt(); // 恢复中断状态
}
}
需要避开的“坑”（常见错误）
吞掉 InterruptedException
这是最常见的错误,这会让中断信号丢失，外部无法停止线程。
// 错误示范
public void bad() {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// 什么都不做，或者只打印日志
// e.printStackTrace();
}
// 线程继续执行，忽略了中断
}
在 finally 块中调用 Thread.interrupted()
Thread.interrupted() 会清除中断标志，如果在 finally 块中不小心调用了它，会破坏中断状态。
// 错误示范
Thread.currentThread().interrupt();
try {
// 一些操作
} finally {
// 这会清除中断状态，导致后续无法检测到中断
System.out.println(Thread.interrupted());
}
对 InterruptedException 进行不恰当的转换
不要将 InterruptedException 转换为 RuntimeException 或 Error 后直接抛出，除非你非常清楚后果，这通常会导致线程无法优雅退出。
最佳实践总结
- 原则是“协作”：不要想着强制停止线程，而是通知它。
- 首选传递中断：如果你的方法是可以被中断的，最好声明
throws InterruptedException，让调用方处理。 - 如果无法声明抛出，则恢复中断状态：在
catch块中调用Thread.currentThread().interrupt()。 - 自定义循环中主动检查：对于长时间运行的循环，定期调用
Thread.currentThread().isInterrupted()。 - 区分
isInterrupted()和interrupted()：isInterrupted()：只检查，不清除。interrupted()：检查并清除（静态方法）。
- 提供优雅的停止机制：除了中断标志位，也可以使用
volatile boolean flag配合中断机制使用，但通常中断标志位已足够。
实际案例：配合线程池
在 ExecutorService 中，中断机制同样重要。
ExecutorService executor = Executors.newFixedThreadPool(10);
Future<?> future = executor.submit(() -> {
while (!Thread.currentThread().isInterrupted()) {
// 执行任务
}
});
// 主线程决定停止这个任务
future.cancel(true); // 这实际上会调用 future 对应线程的 interrupt() 方法
当调用 future.cancel(true) 时，它会中断运行该任务的线程，如果你的任务正确处理了中断，它就能优雅地停止。
总结一句话： 正确处理线程中断，就是在收到中断信号时，做好清理工作，然后尽快退出，而不是忽略或随意处理它。
