怎么在java中关闭一个thread
怎么在java中关闭一个thread
我们经常需要在java中用到thread,我们知道thread有一个start()方法可以开启一个线程。那么怎么关闭这个线程呢?
有人会说可以用Thread.stop()方法。但是这个方法已经被废弃了。
根据Oracle的官方文档,Thread.stop是不安全的。因为调用stop方法的时候,将会释放它获取的所有监视器锁(通过传递ThreadDeath异常实现)。如果有资源该监视器锁所保护的话,就可能会出现数据不一致的异常。并且这种异常很难被发现。 所以现在已经不推荐是用Thread.stop方法了。
那我们还有两种方式来关闭一个Thread。
- Flag变量
如果我们有一个无法自动停止的Thread,我们可以创建一个条件变量,通过不断判断该变量的值,来决定是否结束该线程的运行。
public class KillThread implements Runnable {
private Thread worker;
private final AtomicBoolean running = new AtomicBoolean(false);
private int interval;
public KillThread(int sleepInterval) {
interval = sleepInterval;
}
public void start() {
worker = new Thread(this);
worker.start();
}
public void stop() {
running.set(false);
}
public void run() {
running.set(true);
while (running.get()) {
try {
Thread.sleep(interval);
} catch (InterruptedException e){
Thread.currentThread().interrupt();
log.info("Thread was interrupted, Failed to complete operation");
}
// do something here
}
log.info("finished");
}
public static void main(String[] args) {
KillThread killThread= new KillThread(1000);
killThread.start();
killThread.stop();
}
}
上面的例子中,我们通过定义一个AtomicBoolean 的原子变量来存储Flag标志。
我们将会在后面的文章中详细的讲解原子变量。
- 调用interrupt()方法
通过调用interrupt()方法,将会中断正在等待的线程,并抛出InterruptedException异常。
根据Oracle的说明,如果你想自己处理这个异常的话,需要reasserts出去,注意,这里是reasserts而不是rethrows,因为有些情况下,无法rethrow这个异常,我们需要这样做:
Thread.currentThread().interrupt();
这将会reasserts InterruptedException异常。
看下我们第二种方法怎么调用:
public class KillThread implements Runnable {
private Thread worker;
private final AtomicBoolean running = new AtomicBoolean(false);
private int interval;
public KillThread(int sleepInterval) {
interval = sleepInterval;
}
public void start() {
worker = new Thread(this);
worker.start();
}
public void interrupt() {
running.set(false);
worker.interrupt();
}
public void stop() {
running.set(false);
}
public void run() {
running.set(true);
while (running.get()) {
try {
Thread.sleep(interval);
} catch (InterruptedException e){
Thread.currentThread().interrupt();
log.info("Thread was interrupted, Failed to complete operation");
}
// do something here
}
log.info("finished");
}
public static void main(String[] args) {
KillThread killThread= new KillThread(1000);
killThread.start();
killThread.interrupt();
}
}
上面的例子中,当线程在Sleep中时,调用了interrupt方法,sleep会退出,并且抛出InterruptedException异常。
本文的例子请参考https://github.com/ddean2009/learn-java-concurrency/tree/master/kill-thread
更多教程请参考 flydean的博客
最新文章
- [原创]LoadRunner 12.02 录制脚本时提示无Internet访问,如何解决?
- 微信官方demo(php)
- Merge Intervals 运行比较快
- [archlinux][hardware] 查看SSD的使用寿命
- ecshop绕过验证码暴力破解
- 14、C#基础整理(函数)
- POJ 2516 Minimum Cost [最小费用最大流]
- Maximum Product Subarray JAVA实现
- 小程序原理,生成SQL SERVER 2008 数据库所有表的结构文档
- A Statistical View of Deep Learning (II): Auto-encoders and Free Energy
- Tomcat 官网知识总结篇
- 配置chrome支持本地(file协议)ajax请求
- 【MSP是什么】MSP认证之项目管理与项目群管理的区别
- PostMessage和SendMessage的区别
- 基于 HtmlHelper 的自定义扩展Container
- 解决Oracle死锁问题步骤
- Event Recommendation Engine Challenge分步解析第二步
- 苹果应用商店逾千款iOS应用存安全漏洞
- ORA-00444: background process DBRM failed while starting
- Spring Webservices(转)
热门文章
- 前端之jQuery基础篇
- C、Guard the empire(贪心)
- stm32:实现呼吸灯
- ERROR:TypeError: Cannot read property 'upgrade' of undefined
- jQuery extend()和jQuery.fn.extend()区别和详解
- Powershell如何制定属性并输出
- [安卓] 21、android studio 疑难杂症
- redis集群搭建-3.0/4.0版本
- AJ学IOS 之微博项目实战(8)用AFNetworking和SDWebImage简单加载微博数据
- Linux下搭建接口自动化测试平台