java中断线程的正确姿势完整示例
作者:一个程序员的成长 发布时间:2023-01-27 06:33:58
Java停止线程的逻辑(协同、通知)
在Java程序中,我们想要停止一个线程可以通过interrupt方法进行停止。但是当我们调用interrupt方法之后,它可能并不会立刻就会停止线程,而是通知线程需要停止。线程接收到通知之后会根据自身的情况判断是否需要停止,它可能会立即停止,也有可能会执行一段时间后停止,也可能根本就不停止。
那么Java为什么要选择这种非强制性的线程中断呢?其实更多是为了数据安全,保证程序的健壮性。因为我们不知道程序正在做什么事情。如果贸然停止,可能会造成数据的错乱、不完整。
一个简单的例子:
public class _24_ThreadTest implements Runnable {
@Override
public void run() {
int count = 0;
while (!Thread.currentThread().isInterrupted() && count <= 2000) {
System.out.println("count: " + count++);
}
}
public static void main(String[] args) throws Exception {
_24_ThreadTest threadTest = new _24_ThreadTest();
Thread thread = new Thread(threadTest);
thread.start();
Thread.sleep(10);
// 中断线程
thread.interrupt();
}
}
这个例子是一个简单的通过interrupt中断线程的案例,run方法中通过判断当前线程是否中断,并且count是否大于2000来进行循环。如果线程中断则退出循环,线程执行结束。这种就属于线程正常停止的情况。
Sleep是否会收到线程中断信号
public class _24_ThreadTest implements Runnable {
@Override
public void run() {
int count = 0;
while (!Thread.currentThread().isInterrupted() && count <= 2000) {
try {
System.out.println("count: " + count++);
// 子线程睡眠
Thread.sleep(1000 * 2);
System.out.println("方法体:" + Thread.currentThread().isInterrupted());
} catch (InterruptedException e) {
System.out.println("异常:" + Thread.currentThread().isInterrupted());
// 线程中断标志位被重置为false
e.printStackTrace();
}
}
}
public static void main(String[] args) throws Exception {
_24_ThreadTest threadTest = new _24_ThreadTest();
Thread thread = new Thread(threadTest);
thread.start();
Thread.sleep(10);
// 中断线程
thread.interrupt();
}
}
如果在子线程中睡眠中,主线程通过interrupt方法进行中断,那么子线程还能不能收到中断信号。其实在这种情况下线程也是可以接收到信号通知的,这个时候会抛出InterruptedException,并且将线程中断标志位设置为false。
在抛出异常后,线程标志位被设置为false,那么在下次循环判断count没有为false的情况下,还是可以进入循环体的。这个时候线程就无法停止。
执行结果:
案例场景:
在进行一些后台任务通过线程跑的时候,如果在循环中遇到线程中断异常,我们需要终止当前任务,并且告诉客户端当前任务执行失败的是哪条记录,这种情况下就可以通过异常中再次中断的方式来停止线程,并且可以返回给客户端当前出现异常的记录是哪条。而不会是接着执行下去。
解决方法
public class _24_ThreadTest implements Runnable {
@Override
public void run() {
int count = 0;
while (!Thread.currentThread().isInterrupted() && count <= 2000) {
try {
System.out.println("count: " + count++);
// 子线程睡眠
Thread.sleep(1000 * 2);
Thread.currentThread().interrupt();
System.out.println("方法体:" + Thread.currentThread().isInterrupted());
} catch (InterruptedException e) {
// 再次中断
Thread.currentThread().interrupt();
System.out.println("异常:" + Thread.currentThread().isInterrupted());
e.printStackTrace();
}
}
}
public static void main(String[] args) throws Exception {
_24_ThreadTest threadTest = new _24_ThreadTest();
Thread thread = new Thread(threadTest);
thread.start();
Thread.sleep(10);
// 中断线程
thread.interrupt();
}
}
既然我们已经知道,在出现线程中断异常之后线程中断标志位会被重置为false,那么我们可以在异常中手动的再次中断当前线程,那么就可以完全停止线程任务。
来源:https://juejin.cn/post/7131897496241963015
猜你喜欢
- 具体可见http://developer.android.com/tools/debugging/ddms.html。 DDMS为IDE和e
- 如果你是想在java目录下创建多级目录,直接新建package,如图输入然后,取消勾选Compact Empty Middle Packag
- 一、前言虽然jdk1.9版本已经问世,但是许多其他的配套设施并不一定支持jdk1.9版本,所以这里仅带领你配置jdk1.8。而jdk1.9的
- 前言之前在SpringBoot项目中简单使用定时任务,不过由于要借助cron表达式且都提前定义好放在配置文件里,不能在项目运行中动态修改任务
- 本文实例为大家分享了Java实现考试系统的具体代码,供大家参考,具体内容如下说明这里的考试系统是指由学生,老师以及考试机构成的,学生通过用户
- Quick Start在SpringBoot中使用log4j2日志框架,只需三步:引入依赖配置log文件获取Logger实例并输出日志引入依
- 一.Unsafe类的源码分析JDK的rt.jar包中的Unsafe类提供了硬件级别的原子操作,Unsafe里面的方法都是native方法,通
- 前言开篇一个例子,我看看都有谁会?如果不会的,或者不知道原理的,还是老老实实看完这篇文章吧。@Slf4j(topic = "c.V
- 面试题1:说一下你对ReentrantLock的理解?ReentrantLock是JDK1.5引入的,它拥有与synchronized相同的
- @ApiImplicitParam作用在方法上,表示单独的请求参数参数name:参数名。value:参数的具体意义,作用。required:
- 下面给大家介绍下mybatis结果生成键值对的实例代码,具体内容如下所示:在实际应用中我们经常会遇到这样的情况,需要给下拉框赋值,这个时候就
- 使用场景EntityListeners在jpa中使用,如果你是mybatis是不可以用的它的意义对实体属性变化的跟踪,它提供了保存前,保存后
- 首先在pom文件里引入mqtt的依赖配置<!--mqtt--> <d
- 请求参数解析客户端请求在handlerMapping中找到对应handler后,将会继续执行DispatchServlet的doPatch(
- 抽象方法与虚方法的区别先说两者最大的区别:抽象方法是需要子类去实现的。虚方法是已经实现了的,可以被子类覆盖,也可以不覆盖,取决于需求。因为抽
- autoMapping和autoMappingBehavior的区别autoMappingBehaviormybatis核心配置文件中set
- Mybatis-Plus是一个优秀的Mybatis增强工具,目前更新到3.1.1。Mybatis-Plus原生提供了很多单表操作的方法,极大
- (一)单线程递归方式package com.taobao.test;import java.io.File;public class Tot
- 本文主要介绍了Maven实战之搭建Maven * 和镜像的方法(图文),分享给大家,具体如下:准备工作安装3.6.*的Nexus理论Nexus
- Controller简介Controller控制器,是MVC中的部分C,为什么是部分呢?因为此处的控制器主要负责功能处理部分:1、收集、验证