协作,才能更好的中断线程
聊起中断,大家可能最熟悉的例子就是线程休眠。下面就是一个线程休眠的 demo,在这个例子中,当我们调用 sleep
方法,该方法将会抛出一个需要捕获的中断异常,这里捕获该异常并直接返回。
for (int i = 0; i < somethings.size(); i++) {
// 休眠 4 s
try {
Thread.sleep(4000);
} catch (InterruptedException e) {
// 抛出中断异常
return;
}
// 输出
System.out.println(somethings.get(i));
}
除了 InterruptedException
中断异常,另外还有三个中断相关的方法,三个方法都与线程相关。
- thread#interrupt
- Thread#interrupted
- thread#isInterrupted
interrupt
方法用于中断线程,但是并不是说该方法就能直接使线程停止。
下面使用 interrupt
中断线程,这里我们期望中断直接停止子线程输出。但是当主线程调用子线程 interrupt
方法,子线程并却没有被终止,还在继续打印数字。
Runnable interruptedTask=new Runnable() {
@Override
public void run() {
for (int i = 0; i <Integer.MAX_VALUE ; i++) {
System.out.println(i);
}
}
};
Thread interruptThread=new Thread(interruptedTask);
interruptThread.start();
// 休眠 5 s,
TimeUnit.SECONDS.sleep(2);
// 中断当前线程
interruptThread.interrupt();
// 再次休眠,观察子线程
TimeUnit.SECONDS.sleep(2);
引用 Java 官方对于中断的解释:
An interrupt is an indication to a thread that it should stop what it is doing and do something else. It's up to the programmer to decide exactly how a thread responds to an interrupt, but it is very common for the thread to terminate
中断仅仅只是表明这个线程可以停止,但是线程是否停止完全取决于线程自己。只有线程相互协作,才能更好的停止线程。
每个线程都包含一个内部标志,用来表示中断状态。调用线程的 interrupt
方法将会设置该状态位,对于 Thread#sleep
等阻塞方法,将会抛出 InterruptedException
,并清除中断标志。
我们可以使用 thread#isInterrupted
或 Thread#interrupted
检查中断状态。但是需要注意,两个方法存在一些区别,Thread#interrupted
为静态类方法,该方法检测到中断之后就会清除中断标志。
上面的方法我们只要加上中断状态判断就也可以停止线程。
Runnable interruptedTask=new Runnable() {
@Override
public void run() {
for (int i = 0; i <Integer.MAX_VALUE ; i++) {
// 一旦检测到中断标志,停止线程
if(Thread.interrupted()){
System.out.println("interrupted!!!!");
break;
}
System.out.println(i);
}
}
};
Thread interruptThread=new Thread(interruptedTask);
interruptThread.start();
// 休眠 5 s,
TimeUnit.SECONDS.sleep(2);
// 中断当前线程
interruptThread.interrupt();
// 再次休眠,观察子线程
TimeUnit.SECONDS.sleep(2);
}
中断最佳实践
不要随意『吃掉』中断异常
由于中断异常是一个 checked exception,我们不得不需要处理该异常。如果我们可以保证该异常不影响应用,我们可以直接『吃掉』这个异常。其他情况下我们需要正确处理这个异常。
最简单的做法就是不处理该异常,直接向上抛出中断异常,让上层调用者决定如何处理。
但是有些情况下,却不适合上面的做法,这种情况下我们需要在 catch 中处理中断。如果实在不知道如何处理,那就是记录该异常,并使用日志方式输出。
中断不会停止阻塞 IO
上面我们说到,对于一些阻塞方法如 Thread#sleep
,将会抛出中断异常。但是对于 Socket 等阻塞 IO 调用,并不会抛出这个异常。也就是说中断并不会停止阻塞 IO 的调用。
这是因为当调用 Thread#sleep
等阻塞方法时,Java 线程状态将会从 RUNNABLE
转变为 TIMED_WAITING
或 WATTING
。而当线程阻塞在 IO 读取时,Java 线程实际状态却还是 RUNNABLE
。如果你对这个线程状态还有疑惑,可以阅读下这篇文章 面试官:都说阻塞 I/O 模型将会使线程休眠,为什么 Java 线程状态却是 RUNNABLE?,深入理解一下线程状态。
本文首发于studyidea.cn
欢迎关注我的公众号:程序通事,获得日常干货推送。如果您对我的专题内容感兴趣,也可以关注我的博客:studyidea.cn
原文地址:https://www.cnblogs.com/goodAndyxublog/p/11644252.html
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- ASP.NET Core 将文件夹内容输出为压缩包文件方法
- 如何阻止指定类型的SAP CRM附件被上传到服务器
- Docker 之NameSpace与Cgroup
- 微信网页扫码登录和公众号网页授权登录的比较
- 【TBase开源版测评】分布式数据库复制表关联查询
- v-decorator的取值与赋值
- fastjson导致spring security oauth2的token序列化错误
- 微信小程序webview,a锚点跳转,回退时一直保留在原页面
- SLURM使用教程
- MIME 类型大全,你值得收藏
- Jetbrains系列---PyCharm, Goland翻译插件推荐Translation
- 熬夜总结了 “HTML5画布” 的知识点(共10条)
- 在PyTorch中使用深度自编码器实现图像重建
- Django+Vue开发生鲜电商平台之9.个人中心功能开发
- Serverless 实战:通过 Component 实现多地域部署容灾