当前位置: 首页 > news >正文

java中的线程中断

java中的线程中断

  • 1、线程中断 即 线程的取消/关闭的机制
  • 2、线程对中断interrupt()的反应
    • 2.1、RUNNABLE:线程在运行或具备运行条件只是在等待操作系统调度
    • 2.2、WAITING/TIMED_WAITING:线程在等待某个条件或超时
    • 2.3、BLOCKED:线程在等待锁,试图进入同步块
    • 2.4、NEW/TERMINATED:线程还未启动或已结束
    • 2.5、IO操作
  • 3、关于中断的经验

1、线程中断 即 线程的取消/关闭的机制

Java中停止一个线程的主要机制是中断,中断并不是强迫终止一个线程,它是一种 协作机制 ,是给线程传递一个取消/关闭信号,由线程自身来决定如何以及何时退出。

停止线程,但这个方法被标记为了过时。
@Deprecated
public final void stop()
=========================
返回对应线程的中断标志位是否为truepublic boolean isInterrupted()
返回当前线程的中断标志位是否为true,并清空中断标志位。
public static boolean interrupted()
表示中断对应的线程。
public void interrupt()

2、线程对中断interrupt()的反应

2.1、RUNNABLE:线程在运行或具备运行条件只是在等待操作系统调度

举个栗子:

public static void main(String[] args) throws InterruptedException {Thread t = new Thread(() -> {while (!Thread.currentThread().isInterrupted()) {System.out.println("线程t 执行中...");}});t.start();Thread.sleep(1);t.interrupt();System.out.println("main exit");
}

RUNNABLE状态的线程tinterrupt()后,是否终止中断线程由线程t自身代码逻辑决定。

2.2、WAITING/TIMED_WAITING:线程在等待某个条件或超时

线程执行如下方法会进入WAITING状态:
public final void join() throws InterruptedException
public final void wait() throws InterruptedException线程执行如下方法会进入TIMED_WAITING状态:
public final native void wait(long timeout) throws InterruptedException
public static native void sleep(long millis) throws InterruptedException
public final synchronized void join(long millis) throws InterruptedException

举个栗子:

public class ThreadInterrupt {public static void main(String[] args) {Thread t = new Thread(() -> {try {Thread.sleep(10000);} catch (InterruptedException e) {System.out.println("Thread.interrupted() = " + Thread.interrupted());//Thread.interrupted() = falseSystem.out.println("Thread.interrupted() = " + Thread.interrupted());//Thread.interrupted() = false}});t.start();t.interrupt();}
}

捕获到InterruptedException,通常表示希望结束该线程,线程大概有两种处理方式:
向上传递该异常,这使得该方法也变成了一个可中断的方法,需要调用者进行处理。

有些情况,不能向上传递异常,比如Thread的run方法,它的声明是固定的,不能抛出任何受检异常,这时,应该捕获异常,进行合适的清理操作,清理后,一般应该调用Thread的interrupt方法设置中断标志位,使得其他代码有办法知道它发生了中断。

2.3、BLOCKED:线程在等待锁,试图进入同步块

举个栗子:

public class ThreadInterrupt {private final static Object lockObj = new Object();private static class MyBlockedThread extends Thread {@Overridepublic void run() {System.out.println("MyBlockedThread.run = " + Thread.currentThread().isInterrupted());synchronized (lockObj) {while (!Thread.currentThread().isInterrupted()) {System.out.println(Thread.currentThread().isInterrupted());}}System.out.println("exit");}}public static void main(String[] args) throws InterruptedException {synchronized (lockObj) {MyBlockedThread myBlockedThread = new MyBlockedThread();myBlockedThread.start();Thread.sleep(3000);myBlockedThread.interrupt();myBlockedThread.join(); // join方法会等待线程执行完后返回}}
}

myBlockedThread.join();该行代码放开注释掉情况下:线程一直等待锁 BLOCKED。

com.michael.ThreadInterrupt.MyBlockedThread.run = false

myBlockedThread.join();该行代码注释掉情况下:因为主线程不再等待线程myBlockedThread结束,释放锁lock后,线程myBlockedThread会获得锁,然后检测到发生了中断,然后程序退出。

com.michael.ThreadInterrupt.MyBlockedThread.run = false
exit

2.4、NEW/TERMINATED:线程还未启动或已结束

举个栗子:

public static void main(String[] args) throws InterruptedException {Thread t = new Thread(() -> {System.out.println("线程t 执行...");});t.interrupt();System.out.println("NEW = " + t.isInterrupted());t.start();Thread.sleep(100);t.interrupt();System.out.println("TERMINATE = " + t.isInterrupted());
}============ 执行结果 ============
NEW = false
线程t 执行...
TERMINATE = false

2.5、IO操作

如果线程在等待IO操作,尤其是网络IO,则会有一些特殊的处理。

  • 如果IO通道是可中断的,即实现了InterruptibleChannel接口,则线程的中断标志位会被设置,同时线程会收到异常ClosedByInterruptException
  • 如果线程阻塞于Selector调用,则线程的中断标志位会被设置,同时阻塞的调用会立即返回。
  • InputStream的read调用,该操作是不可中断的,如果流中没有数据,read会阻塞 (但线程状态依然是RUNNABLE),且不响应interrupt(),与synchronized类似,调用interrupt()只会设置线程的中断标志,而不会真正"中断"。

3、关于中断的经验

Java中取消/关闭线程技术是中断,但它是一种协作机制,不会强制终止线程。线程在不同状态IO操作时对中断的反应有所不同。
作为线程的实现者:应该提供明确的取消/关闭方法,并用文档描述清楚其行为。
作为线程的调用者:应该使用其取消/关闭方法,而不是贸然调用interrupt()方法。

http://www.lryc.cn/news/156398.html

相关文章:

  • 【跟小嘉学 Rust 编程】二十三、Cargo 使用指南
  • R Removing package报错(as ‘lib’ is unspecified)
  • 金融信创,软件规划需关注自主安全及生态建设
  • 无重叠区间【贪心算法】
  • nlp系列(7)实体识别(Bert)pytorch
  • Uniapp学习之从零开始写一个简单的小程序demo(新建页面,通过导航切换页面,发送请求)
  • uniapp微信小程序隐私保护引导新规
  • 超图嵌入论文阅读2:超图神经网络
  • 安全运营中心(SOC)技术框架
  • 并行和并发的区别
  • GPT转换工具:轻松将MBR转换为GPT磁盘
  • 大模型参数高效微调技术原理综述(二)-BitFit、Prefix Tuning、Prompt Tuning
  • 将conda环境打包成docker步骤
  • C# 获取Json对象中指定属性的值
  • 【LeetCode】202. 快乐数 - hash表 / 快慢指针
  • 什么是多态性?如何在面向对象编程中实现多态性?
  • 【目标检测】理论篇(3)YOLOv5实现
  • IDEA爪哇操作数据库
  • 一文速学-让神经网络不再神秘,一天速学神经网络基础(七)-基于误差的反向传播
  • C++ 异常处理——学习记录007
  • 【BIM+GIS】“BIM+”是什么? “BIM+”技术详解
  • Flink算子如何限流
  • 垃圾分代收集的过程是怎样的?
  • NPM 常用命令(四)
  • Anaconda虚拟环境下导入opencv
  • Linux设备驱动程序
  • mybatis <if>标签判断“0“不生效
  • 企业数据的存储形式与方案选择
  • 图像处理简介
  • adb server version (19045) doesn‘t match this client (41); killing.的解决办法