线程停止继续_晓龙吊打面试官系列： 如何优雅的停止一个线程

一、什么时候我们需要中断一个线程

在实际的开发中，有很多场景需要我们中断一个正在运行的线程，就比如：

  1. 当我们使用抢票软件时，其中某一个通道已经抢到了火车票，这个时候我们就需要通知其他线程停止工作。

  2. 当我们希望在一个限定的时间里获得任务结果的时候，也需要在任务超时的时候关闭它

但是Java并不能像代码块中的break一样干脆的退出线程运行，Java本身提供的API方法总是让人觉得差强人意，没有办法完美的解决我们的需求，那么我们该如何优雅的停止一个线程呢？

二、如何终止一个线程

1) 暴力停止

1. 使用stop方法停止线程

Java在停止线程的运行方面，提供了一个stop的方法，首先我们写段代码，演示stop方法是如何终止线程的：

package xiao.thread.stop;

public class StopThread {
private static int count;

public static void main(String[] args) throws InterruptedException {
// first :create a thread task
		Thread thread = new Thread(() -> {
while (true) {
++count;
// 为了减少打印数 增加个计数判断 
//也可调用sleep方法进行休眠
if (count % 100 == 0) {
					System.out.println("此时线程依旧存活" + count);
}
}
}, "thread_task for stopThread");
		thread.start();
// 如果直接终止 很有可能thread的run方法还没有开始执行 所以建议让main线程休眠一段时间来观察效果
		Thread.currentThread().sleep(1_000);
		thread.stop();
}
}

首先我们可以明显的观察到，当我们调用stop的时候，线程被暴力停止了。这种方式虽然简单，但是java语言本身并不提倡我们这么做。stop()方法呈删除线状态，已经表明了这个方法已经被弃用。

2. 为什么不提倡使用stop方法

其实不提倡使用stop方法的原因很简单，因为线程最优状态的终止是只能自杀而不能被杀。具体的来说就是：当我们通过其他线程调用stop方法时，此刻我们并不知道被杀死的线程执行到了哪里。就比如我们在做一个为集合添加数据的操作，我们此时无法知道数据的添加进行到了哪一步。而当我们调用stop方法，此时被杀死的线程会立即释放自身持有的锁，其他线程此时就可以看到未被处理完的数据，造成线程安全的问题，破坏了对象的一致性。

2) 捕获异常法

1. 中断机制

中断很好理解，它本身其实并不具备中断的能力，只是一种协作机制。在java中并没有对中断进行任何语法层面的实现，只能够靠我们利用已有的中断标识来记性业务处理达到中断的目的。

2. 相关API

cf77e60e33bf14c872051263e1db1e7e.png
在实现中断功能时，我们常用的API主要是三个方法：

1. public void interrupt
调用此方法会将线程的中断标识设为true2. public boolean isInterrupt
调用此方法将会返回此刻现成的中断标识3.public static boolean interruped
该方法只能通过Thread.interrupted()调用，他会做两个操作
第一步返回当前线程的中断状态
第二部将当前现成的中断标识设为false

3. 证实interrupt没有停止线程的能力

首先我们举个小例子来证明当我们调用interrupt方法时，jvm无法为我们中断目标线程：

public class InterruptThread {

private static int count;

public static void main(String[] args) {
		Thread thread = new Thread(() -> {
while (true) {
				System.out.println("线程依旧存活:_此时计数器状态为_" + ++count);
try {
					Thread.currentThread().sleep(1_000);
} catch (InterruptedException e) {
}

}
},"测试线程");
		thread.start();
		thread.interrupt();
}

}

我们看下输出结果：825819616f2bd57d43c2e2958e9674d6.png
虽然我们在调用start方法后立即调用了interrupt，但是目标的测试线程依旧每隔一秒在控制台打印了计数器状态，并没有实际的中断线程，通过这个例子我们证明了在我们调用interrupt的时候，jvm并没有立即为我们停止目标线程的运行，如果我们想要在调用interrupt之后停止线程该如何做呢？

4. 异常处理法停止线程

既然我们证实了jvm确实不会主动地替我们中断线程，那么我们就需要利用interrupt方法中提到的中断标识来做一些事情。首先我们需要证明一个新的论点：

当阻塞方法接收到中断信号的时候，会抛出一个InterruptedException 异常

那么我们改造下上面的代码：

public class InterruptThread {
private static int count;
public static void main(String[] args) throws InterruptedException {
		Thread thread = new Thread(() -> {
while (true) {
				System.out.println(Thread.currentThread().getName()+"正在运行~");
try {
					Thread.currentThread().sleep(2_500);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
					e.printStackTrace();
					System.out.println(Thread.currentThread().getName()+"接收到中断异常");
}
}

}, "测试线程");
		thread.start();
		Thread.currentThread().sleep(1_000);
		thread.interrupt();
}
}

运行结果：bdd1b40668d6dde94840484bc58ceb73.png
在这里我们可以看出，当我们调用interrupt方法时，由于线程此时也调用了可能将线程阻塞的方法sleep，因此此时目标线程在收到我们的中断信号的时候抛出了interruptException，但是由于while方法体里面还有代码需要执行，线程此时并没有结束，这个时候我们就需要利用我们捕获到的异常改造下代码:

public class InterruptThread {
private static int count;
private static boolean mark = true ;
public static void main(String[] args) throws InterruptedException {
		Thread thread = new Thread(() -> {
while (mark) {
				System.out.println(Thread.currentThread().getName()+"正在运行~");
try {
					Thread.currentThread().sleep(2_500);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
					e.printStackTrace();
					mark = false ;
					System.err.println(Thread.currentThread().getName()+"接收到中断信号");
}
}
}, "测试线程");
		thread.start();
		Thread.currentThread().sleep(1_000);
		thread.interrupt();
}
}

运行结果:ec0750e4d686ca2f1e5b6ffd6f37b51f.png
可以看出程序在接收到我们的中断信号后就没有继续运行，线程停止。而上面代码的变化其实就发生在while的判断条件上，我们加入了一个布尔变量mark，通过捕获异常停止线程的原理其实也很简单：我们认为的设置一个中断变量，将该值设置为代码运行的入口条件，当我们捕获到异常的时候，改变中断变量的值以达到跳出循环的目的从而实现停止线程。
当然，实现跳出循环的方式有很多，我们也可以通过return关键字实现跳出循环的效果：

public class InterruptThread {
public static void main(String[] args) throws InterruptedException {
		Thread thread = new Thread(() -> {
while (true) {
				System.out.println(Thread.currentThread().getName()+"正在运行~");
try {
					Thread.currentThread().sleep(2_500);
} catch (InterruptedException e) {
					e.printStackTrace();
					System.err.println(Thread.currentThread().getName()+"接收到中断信号");
return ;
}
}
}, "测试线程");
		thread.start();
		Thread.currentThread().sleep(1_000);
		thread.interrupt();
}
}

运行结果：7cc73c196447fb383527876e6a8fae74.png
通过return也可以很好地利用异常来结束线程的运行。

当然，我们还有个关于interruptException异常的问题要说下

在实际的开发中，我们不能不管不顾的通过抛出异常的方式来结束线程，如果你只是想记录日志，那么此时应该将中断标记重新置为false，以避免程序意外中断

3) 通过守护线程实现(了解即可)

我们也可以利用守护线程的特性来结束一个线程的运行

如果不了解守护线程的特性,可以看我之前的文章
线程的简介

下面我们先看代码实现:

public class DaemonThreadInterrupt {
public static Thread thread;
public boolean flag = true;

public void execut(Runnable task) {
		thread = new Thread(()->{
			Thread thread2 = new Thread(task，"任务线程");
			thread2.setDaemon(true);
			thread2.start();
try {
				thread2.join();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
				e.printStackTrace();
}
},"执行线程");
		thread.start();

}

public void stop() {
		thread.interrupt();
}

public static void main(String[] args) {
		DaemonThreadInterrupt daemonThreadInterrupt = new DaemonThreadInterrupt();
		daemonThreadInterrupt.execut(()->{
while(true) {
				System.out.println("程序运行");
try {
					thread.sleep(1_000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
					e.printStackTrace();
}
}
});
		daemonThreadInterrupt.stop();
}
}

实现原理:
在上述代码中,我将需要实现的任务线程放到了一个执行线程中,执行线程不负责任何业务逻辑的处理,只负责启动任务线程。而任务线程在启动后，将他设为了执行线程的守护线程。然后让他join到执行线程中。
然后接下来我们就利用了join方法的特性以及守护线程的特点设计了stop方法：
执行join方法后，执行线程将等待任务线程执行完毕后才会执行，但是当我们调用interrupt方法时，join方法接收到中断信号就会抛出异常，此时执行线程不在等待任务线程的运行。重点来了：此时执行线程执行完毕，任务线程作为执行线程的守护线程也结束了他的生命周期。
这种方式充分利用了线程的多种特性停止了一个线程，而且结束的过程可控，也可设置延时结束，适合用作定时任务线程的实现。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/489234.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

hive读取hdfs存放文件_数据获取层之Flume快速入门（一） 实时监控单个追加文件

hive读取hdfs存放文件_数据获取层之Flume快速入门（一） 实时监控单个追加文件

实时监控 Hive 日志，并上传到 HDFS 中实现步骤1、Flume 要想将数据输出到 HDFS，必须持有 Hadoop 相关 jar 包commons-configuration-1.6.jar、hadoop-auth-2.7.2.jar、hadoop-common-2.7.2.jar、hadoop-hdfs-2.7.2.jar、commons-io-2.4.jar、htrace-core…
阅读更多...
2019-2020中国趋势报告，203页PPT解读16大机会

2019-2020中国趋势报告，203页PPT解读16大机会

来源：企鹅智库 报告如下未来智能实验室是人工智能学家与科学院相关机构联合成立的人工智能，互联网和脑科学交叉研究机构。未来智能实验室的主要工作包括：建立AI智能系统智商评测体系，开展世界人工智能智商评测；开展互联…
阅读更多...
行程单图片python预处理_GCC编译过程（预处理-gt;编译-gt;汇编-gt;链接）

行程单图片python预处理_GCC编译过程（预处理-gt;编译-gt;汇编-gt;链接）

前言如果你使用集成环境开发。那么你点击编译按钮就可生成可执行文件。但是C程序从源代码到二进制行程序都经历了那些过程？你知道吗？这些过程集成开发环境在点击编译按钮后都做完了，如果编译没有出错，即可生成可执行文件。本文将以…
阅读更多...
sqlite查询乘以某列如果是null就换成_大数据之Hive group by with cube/rollup分组查询...

sqlite查询乘以某列如果是null就换成_大数据之Hive group by with cube/rollup分组查询...

group bysql 查询时，我们常将聚合函数和group by 结合起来对某一个或多个字段进行分组查询，例如：select addcode,count(distinct sbtid)uv from tb_hive_window group by addcode;---------------| addcode | uv |---------------| 0002 …
阅读更多...
可以操作excel吗_Excel快速填充，这四种方法你会吗？操作逆天告别加班

可以操作excel吗_Excel快速填充，这四种方法你会吗？操作逆天告别加班

在Excel的表格制作中，仅仅会复制粘贴可是不够的，还需要掌握更多的技能，来提升我们的工作效率！我们在进行Excel报表制作的时候，如果要批量填充序号，有多少种方法呢？下面给大家简单介绍一下这四种…
阅读更多...
2G---5G与未来天线技术

2G---5G与未来天线技术

本文来源：滤波器过去二十年，我们见证了移动通信从1G到4G LTE的转变。在这期间，通信的关键技术在发生变化，处理的信息量成倍增长。而天线，是实现这一跨越式提升不可或缺的组件。按照业界的定义，天线是一种变…
阅读更多...
python操作csv文件第7行开始的数据_Python教程-Python读写CSV文件

python操作csv文件第7行开始的数据_Python教程-Python读写CSV文件

前言 本教程学习在Python中使用CSV文件。CSV（逗号分隔值）格式是在电子表格和数据库中使用的非常流行的导入和导出格式。Python语言包含该模块，该模块具有用于读取和写入CSV格式的数据的类。csv 使用csv.reader（）读取CS…
阅读更多...
基于STM32的高精度频率计设计

基于STM32的高精度频率计设计

前言 本文记录了博主完成的一个课设作品（学分为3.5分），题目需要利用ARM做出一个高精度频率计。具体要求如下： 1）实现对10M以内数字信号频率的高精度测量，频率测量误差不大于0.01%； 2&#xff0…
阅读更多...
数学的意义(一)

数学的意义(一)

来源： 数学职业家数学既是一种文化、一种“思想的体操”，更是现代理性文化的核心。马克思说：“一门科学只有当它达到了能够成功地运用数学时，才算真正发展了。”在前几次科技革命中，数学大都起到先导和支柱作用。我们不…
阅读更多...
python弹球小游戏程序_Python实现弹球小游戏

python弹球小游戏程序_Python实现弹球小游戏

本文主要给大家分享一个实战项目，通过python代码写一款我们儿时大多数人玩过的游戏---小弹球游戏。只不过当时，我们是在游戏机上玩，现在我们通过运行代码来玩，看看大家是否有不一样的体验，是否可以重温当年的乐趣呢&am…
阅读更多...
强化学习决策生成-以 Q-learning 为例

强化学习决策生成-以 Q-learning 为例

强化学习决策生成-以 Q-learning 为例
阅读更多...
【数据中台】关于数据中台系统，需要了解哪些技术？

【数据中台】关于数据中台系统，需要了解哪些技术？

来源：产业智能官国家建材大数据研究中心今天让我们全面解读中台，包括企业为什么要平台化，目前中台都有哪些形式，实施中台系统的优势、面临的问题以及建议都有哪些？中台这个概念早期是由美军的作战体系演化而来的&#…
阅读更多...
什么是启发式？什么是产生式？

什么是启发式？什么是产生式？

来源：人机与认知实验室一般而言，机器常常被设定从已知推未知，而人们不时会从未知（假设）推未知，特殊情形下也有从未知推已知的，这些推导中常见的有产生式和启发式，那么究竟什么是产生…
阅读更多...
Maven项目错误解决小结

Maven项目错误解决小结

http://blog.csdn.net/typa01_kk/article/details/49185759 Maven项目错误解决小结 注：整理错误，不喜欢为了一个小问题，占篇幅，所以请CtrlF自己查看，定位问题，愿为解决. 注：网络上的错误解决经验…
阅读更多...
python交并补_python两个列表求交、并、差

python交并补_python两个列表求交、并、差

在python中，如果有两个数组，分别要求交集，并集与差集，怎么实现比较方便呢？ 当然最容易想到的是对两个数组做循环，即写两个for循环来实现。这种写法大部分同学应该都会，而且也没有太多的技术含量…
阅读更多...
可怕！贺建奎论文手稿意外曝光！基因编辑实验充满谎言

可怕！贺建奎论文手稿意外曝光！基因编辑实验充满谎言

来源：学研加中国双胞胎的基因编辑可能已经失败，并产生了意想不到的突变。这是科学家们阅读了原南方科技大学副教授贺建奎论文手稿后，得出的结论。贺建奎基因编辑婴儿事件2018年11月26日，一则《世界首例免疫艾滋病的基因编辑婴儿在…
阅读更多...
l360废墨收集垫清零_知识分享003:EPSON L360打印机出现故障-废墨计数清零

l360废墨收集垫清零_知识分享003:EPSON L360打印机出现故障-废墨计数清零

故障现象：客户的EPSON L360打印机出现故障，纸张和墨水报警灯交替闪烁。无法打印原因分析：确定纸张和墨水的是处于正常状态，上网查了，可能是废墨收集到达了上限。需要做清零处理。解决方法：根据这个型号EPSO…
阅读更多...
R语言-处理异常值或报错的三个示例

R语言-处理异常值或报错的三个示例

R语言-处理异常值或报错的三个示例 之前用rvest帮人写了一个定期抓取amazon价格库存，并与之前价格比较的小程序，算是近期写过的第一个完整的程序了。里面涉及了一些报错的处理。 这里主要参考了stackoverflow上的以下问答： How to skip an er…
阅读更多...
联想e580没有声音_现在你可以购买通过 Linux 认证的联想 ThinkPad 和 ThinkStation

联想e580没有声音_现在你可以购买通过 Linux 认证的联想 ThinkPad 和 ThinkStation

曾经有一段时间，ThinkPad 是 Linux 用户的首选系统。但那是在 ThinkPad 还是 IBM 的产品的时候。来源：https://linux.cn/article-12283-1.html作者：Abhishek Prakash译者：Xingyu.Wang曾经有一段时间，ThinkPad 是 Linux…
阅读更多...
UC伯克利教授Stuart Russell人工智能基础概念与34个误区

UC伯克利教授Stuart Russell人工智能基础概念与34个误区

来源：数据简化DataSimp数据简化DataSimp导读：UC伯克利教授StuartRussell人工智能基础概念与34个误区，Russell是加州大学伯克利分校人工智能系统中心创始人兼计算机科学专业教授，同时还是人工智能领域里「标准教科书」《人工智能&a…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023