未加星标

Java 线程的终止与线程中断

字体大小 | |
[系统(linux) 所属分类 系统(linux) | 发布者 店小二04 | 时间 20160901 | 作者 红领巾 ] 0人收藏点击收藏

关于线程终止:

 1、一般来讲线程在执行完毕后就会进入死亡状态,那该线程自然就终止了。

 2、一些服务端的程序,可能在业务上需要,常驻系统。它本身是一个无穷的循环,用于提供服务。那对于这种线程我们该如何结束它呢。

 一、线程的终止

  在Thread类中JDK给我们提供了一个终止线程的方法stop(); 该方法一经调用就会立即终止该线程,并立即释放对象锁。如果当一个线程执行一半业务而调用了该方法,可能就会产生数据不一致问题。

  数据一致性:同一时间点,你在节点A中获取到key1的值与在节点B中获取到key1的值应该都是一样的。

  例如:数据库中维护一张用户 student 表 ,表里有两条数据 :

id=1 name="大A"
id=2 name="小a"

如果我们使用一个 Student 对象来保存这些记录,那么该对象要么保存id=1 de 记录 , 要么保存id=2的记录。如果这个Student对象一半保存id=1的记录 一半保存id=2 的记录(即 id=1 name="小a"), 那么数据就出现了数据一致性问题。

看图来说明stop为什么会产生数据一致性问题:

Java 线程的终止与线程中断

  读与写操作每次都要活的student对象锁,只有获得该锁的线程才有权利操作该对象,也就是说student对象锁的作用就是为了维护对象的一致性,如果线程在写入数据写到一半时 ,调用stop方法,那该对象就会被破坏同时也会释放该对象锁,另外一个等待该锁的读线程就会获得锁,执行操作读到的数据显然是错误的。

代码示例:

public class StopTest2 {
private static Student student=new Student();
public static void main(String[] args) {
new Thread(new Thread_read()).start();
while(true){
Thread thread_writer=new Thread(new Thread_writer());
thread_writer.start();
try {
Thread.sleep(1500);
} catch (InterruptedException e) {
e.printStackTrace();
}
thread_writer.stop();
}
}
static class Thread_read implements Runnable{
@Override
public void run() {
while(true){
synchronized (student){//对共享资源加锁,使读写分离互不影响 ,维护对象的一致性
try {Thread.sleep(100);
} catch (InterruptedException e) {e.printStackTrace();
}
if(student.getId()!=Integer.parseInt(student.getName())){System.out.println("错误资源:"+student);
}else{System.out.println("正确资源:"+student);
}
}
Thread.yield();//释放cup执行权
}
}
}
static class Thread_writer implements Runnable{
@Override
public void run() {
while(true){
synchronized (student){//对共享资源加锁,使读写分离互不影响,维护对象的一致性
int mm=new Random().nextInt(10);
student.setId(mm);
try {Thread.sleep(1000);
} catch (InterruptedException e) {e.printStackTrace();
}
student.setName(String.valueOf(mm));
}
Thread.yield();//释放cup执行权
}
}
}
}
class Student{
private int id=0;
private String name="0";
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
@Override
public String toString() {
return "Student [id=" + id + ", name=" + name + "]";
}
}

执行结果:

错误资源:Student [id=5, name=8]
错误资源:Student [id=4, name=8]
错误资源:Student [id=2, name=5]

如何让正确的终止线程:由程序自行决定线程的终止时间。定义一个标识,通过改变标识来控制程序是否执行。

static class Thread_writer implements Runnable{
private boolean flag=false;
public void setFlag(boolean flag){
this.flag=flag;
}
@Override
public void run() {
while(!flag){
synchronized (student){//对共享资源加锁,使读写分离互不影响,维护对象的一致性
int mm=new Random().nextInt(10);
student.setId(mm);
try {Thread.sleep(1000);
} catch (InterruptedException e) {e.printStackTrace();
}
student.setName(String.valueOf(mm));
}
Thread.yield();//释放cup执行权
}
}
}

二、线程的中断

在上面我们发现使用stop终止线程会照成数据一致性问题,于是我们通过控制标识来控制线程的终止,那JDK有没有合适的终止线程的方式呢?那就就是“线程中断”   

线程中断就是让目标线程停止执行,但它不会使线程立即终止,而是给线程发送一个通知,告诉线程jvm希望你退出执行,至于目标线程何时退出,则完全由它自己决定(如果立即停止,会造成与stop一样的问题)。

JDK中线程中断相关的三个方法:

//线程中断
public void interrupt(){}
//判断线程是否中断
public boolean isInterrupted() {}
//判断线程是否中断,并清除当前中断状态
public static boolean interrupted(){}

1、使用线程中断就一定会中断线程吗?

public class InterruptTest {
public static void main(String[] args) {
Thread thread=new Thread(){
@Override
public void run() {
while(true){
System.out.println("========true======");
}
}
};
thread.start();
try {
Thread.sleep(0);
} catch (InterruptedException e) {
e.printStackTrace();
}
thread.interrupt();//调用线程中断方法
}
}

运行该代码发现该线程并没有终止。

2、如何终止线程

public class InterruptTest {
public static void main(String[] args) {
Thread thread=new Thread(){
@Override
public void run() {
while(true){
if(this.isInterrupted()){//判断当前线程是否是中断状态System.out.println("========true======");break;
}
}
}
};
thread.start();
try {
Thread.sleep(0);
} catch (InterruptedException e) {
e.printStackTrace();
}
thread.interrupt();//调用线程中断方法
}
}

看代码可以发现这与我们自行控制线程的终断类似。

3、当interrupt() 遇到 sleep() / join ()/wait()时 ,在这里以sleep() 为例子

public static native void sleep(long millis) throws InterruptedException;

看源码可知sleep() 方法 InterruptedException 中断异常,该异常不是运行时异常,所以需要捕获它,当线程在执行sleep()时,如果发生线程中断,这个异常就会产生。该异常一旦抛出就会清除中断状态。

看代码:

public class InterruptTest {
public static void main(String[] args) throws InterruptedException {
Thread thread=new Thread(){
@Override
public void run() {
while(true){
System.out.println("线程状态"+this.isInterrupted());
if(Thread.currentThread().isInterrupted()){//判断当前线程是否是中断状态System.out.println("========true======");break;
}
try {Thread.sleep(1000);System.out.println("===========sleep()结束===========");
} catch (InterruptedException e) {System.out.println("异常:"+e.getMessage());// Thread.currentThread().interrupt();
}
}
}
};
thread.start();
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("=========interrupt()=============");
thread.interrupt();//调用线程中断方法
}
}

执行结果:

线程状态false
=========interrupt()=============
异常:sleep interrupted
线程状态false
===========sleep()结束===========
线程状态false
===========sleep()结束===========
线程状态false
===========sleep()结束===========

由于线程中断的状态被 InterruptedException 异常清除了,所以if()条件中的状态一直是false ,因此该线程不会被终止。如果去掉注释就可以达到线程终止的目的(再次中断自己,设置中断状态)。

本文地址:http://www.linuxidc.com/Linux/2016-09/135343.htm


Java 线程的终止与线程中断

本文系统(linux)相关术语:linux系统 鸟哥的linux私房菜 linux命令大全 linux操作系统

主题: Java数据Linux行权常清数据库
分页:12
转载请注明
本文标题:Java 线程的终止与线程中断
本站链接:http://www.codesec.net/view/483468.html
分享请点击:


1.凡CodeSecTeam转载的文章,均出自其它媒体或其他官网介绍,目的在于传递更多的信息,并不代表本站赞同其观点和其真实性负责;
2.转载的文章仅代表原创作者观点,与本站无关。其原创性以及文中陈述文字和内容未经本站证实,本站对该文以及其中全部或者部分内容、文字的真实性、完整性、及时性,不作出任何保证或承若;
3.如本站转载稿涉及版权等问题,请作者及时联系本站,我们会及时处理。
登录后可拥有收藏文章、关注作者等权限...
技术大类 技术大类 | 系统(linux) | 评论(0) | 阅读(18)