Java 中的线程中断
- 1、什么是线程中断
- 2、如何触发线程中断
- 3、如何处理线程中断
- 3.1 线程中断相关的核心方法
- 3.2 处理中断的典型方式
- 3.3 注意事项
- 4、线程中断与线程终止的区别
- 5、线程中断的应用场景
- 5.1 长时间运行任务的取消
- 5.2 阻塞操作的快速响应
- 5.3 服务或线程池的优雅关闭
- 5.4 超时控制
- 5.5 事件驱动架构
- 6 线程中断的常见问题
本篇文章将详细介绍什么是线程中断、如何触发线程中断、如何处理线程中断、线程中断与线程终止的区别 以及线程中断的应用场景。
1、什么是线程中断
Java线程中断是一种线程间协作机制，用于通知线程应在合适的时候停止当前任务。中断并非强制终止线程，而是通过设置线程的中断标志位，由线程自身检查并决定如何处理。
2、如何触发线程中断
-
使用
Thread.interrupt()方法
该方法向目标线程发送中断信号，设置其中断标志位为true。若线程处于阻塞状态（如wait()、sleep()），会抛出InterruptedException并清除中断标志。 -
如果任务通过线程池submit()方法提交到线程池中执行，可使用
Future.cancal(true)发送中断信号
Future.cancal(true)会获取到 阻塞在Future.get()的线程实例，然后调用thread.interrupt()方法。
3、如何处理线程中断
3.1 线程中断相关的核心方法
-
interrupt()
向目标线程发送中断信号，设置其中断标志位为true。若线程处于阻塞状态（如wait()、sleep()），会抛出InterruptedException并清除中断标志。 -
isInterrupted()
检查线程的中断标志位状态，不会清除标志位。 -
Thread.interrupted()
静态方法，检查当前线程的中断状态并清除标志位（即重置为false）。
3.2 处理中断的典型方式
响应中断的阻塞操作
当线程调用如sleep()、wait()等方法时，需捕获InterruptedException并恢复中断状态（避免吞没中断信号），因为 InterruptedException 会清除中断状态：
try {Thread.sleep(1000);
} catch (InterruptedException e) {Thread.currentThread().interrupt(); // 重新设置中断标志// 执行清理或退出逻辑
}
主动检查中断状态
通过循环中检查isInterrupted()实现协作式终止：
while (!Thread.currentThread().isInterrupted()) {// 执行任务逻辑
}
3.3 注意事项
- 不可逆性：抛出
InterruptedException后中断标志会被清除，需手动恢复。 - 非强制终止：线程可以忽略中断，但通常不推荐。
- 资源清理：应在中断处理中释放资源（如关闭文件、网络连接）。
4、线程中断与线程终止的区别
- 线程中断：是线程间协作机制，不强制终止线程的执行，依赖线程自身响应。
- 强制终止（已废弃的
stop()）：直接终止线程，可能导致资源未释放或数据不一致，不推荐使用。
5、线程中断的应用场景
5.1 长时间运行任务的取消
当线程执行耗时操作（如I/O阻塞、复杂计算）时，外部可通过中断信号请求终止任务。例如：
Thread worker = new Thread(() -> {while (!Thread.currentThread().isInterrupted()) { // 当收到中断信号时退出循环// 执行任务逻辑}
});
worker.start();
worker.interrupt(); // 发起中断请求
5.2 阻塞操作的快速响应
线程在Object.wait()、Thread.sleep()、或BlockingQueue.take()等阻塞方法时，调用interrupt()会抛出InterruptedException，立即终止等待状态：
try {Thread.sleep(1000);
} catch (InterruptedException e) {Thread.currentThread().interrupt(); // 恢复中断状态// 清理资源
}
5.3 服务或线程池的优雅关闭
线程池通过中断所有工作线程实现关闭。ExecutorService.shutdownNow()内部会遍历线程并调用interrupt()，任务需检查中断状态主动退出。
5.4 超时控制
结合Future.cancel(true)，可中断正在执行的异步任务。若任务未响应中断，超时后仍可能继续占用资源。
5.5 事件驱动架构
在生产者-消费者模型中，中断可用于紧急停止消费者线程。例如当系统内存不足时，中断日志写入线程避免OOM。
6 线程中断的常见问题
为什么发送线程中断后我的线程还在执行？
调用 interrupt 只是在线程中设置一个标记，并不会强制终止线程。如果线程执行的代码逻辑中没有 Thread.currentThread().isInterrupted() 或 Thread.interrupted() 的检测逻辑和退出语句则线程执行不会受到任何影响。
为什么我无法检测到线程中断？
需要注意 抛出的 InterruptedException 异常和调用 Thread.interrupted() 会清除中断状态，之后判断线程的中断状态则是 false。正确的做法是使用 Thread.currentThread().interrupt(); 重新设置中断状态，后续逻辑才能继续判断是否中断。
