java中断线程的正确姿势完整示例
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，那么我们可以在异常中手动的再次中断当前线程，那么就可以完全停止线程任务。
总结
上面我们简单介绍了如何正确的停止线程，如果在以后的面试中被问到这类问题，那么你是不是可以流畅的回答面试官了。
在run方法中遇到异常，我们是不能直接生吞的，一定要做处理，你可以是简单的日志记录，也可以中断线程。但就是不能不做任何处理。
其实还有其他的一些方法来停止线程，比如stop()，这类方法已被舍弃，这种强制停止可能会引起线程的数据安全问题，所以已经不再推荐使用了。
以上就是java中断线程的正确姿势完整示例的详细内容，更多关于java中断线程的资料请关注脚本之家其它相关文章！
相关文章
Java 中Comparable和Comparator区别比较
本文，先介绍Comparable 和Comparator两个接口，以及它们的差异；接着，通过示例，对它们的使用方法进行说明2013-09-09
这篇文章主要介绍了SpringMVC找不到Controller路径的解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-06-06
这个章节会很烧脑，需要认真研读，我会尽量写的详细一些。 方法和函数，看似是两个概念，其实他严格来说也是两个概念，但我们大可以理解成是同一个概念，在使用时只有语法上的细微差别，是很类似的，都理解为function即可2022-12-12
这篇文章主要介绍了使用kafka如何选择分区数及kafka性能测试，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-08-08
spring boot配置dubbo方式(properties)
这篇文章主要介绍了spring boot配置dubbo方式(properties)，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-01-01
对于如何将一个java文件通过命令形式进行打包,通过以下示例进行讲解,代码简单易懂,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧2023-12-12
Java输出通过InetAddress获得的IP地址数组详细解析
由于byte被认为是unsigned byte，所以最高位的1将会被解释为符号位，另外Java中存储是按照补码存储，所以1000 0111会被认为是补码形式，转换成原码便是1111 0001，转换成十进制数便是-1212013-09-09
本文主要介绍了浅谈SpringBoot如何启动嵌入式Tomcat，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-08-08
本文主要介绍了Spring 中 使用腾讯云发送短信验证码，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2022-03-03
这篇文章主要介绍了springboot中非容器类如何获取配置文件数据问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2024-01-01
最新评论