java 线程的终止与线程中断

关于线程终止:

 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为什么会产生数据一致性问题:

  读与写操作每次都要活的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();//调用线程中断方法
    }
}

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

如何终止线程

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();//调用线程中断方法
    }
}

看代码可以发现这与我们自行控制线程的终断类似。但线程中断的方式更厉害。

时间: 2024-11-03 22:50:43

java 线程的终止与线程中断的相关文章

安全终止MFC线程

终止线程 有两种情况可以使线程结束:控制函数结束或者根本就不允许线程完成,而提前终止它.我们可以想象在WORD中进行后台打印,如果打印结束了,那线程就可以结束了.如果用户中止了打印,那后台打印线程也要终止了.本文将主要介绍对这两种情况的实现,并且介绍如何获得线程的结束代码. 1.对于工作线程,结束它是比较容易的:退出线程函数然后返回一个结束原因的代码就是了.用户可以使用AfxEndThread函数或直接利用return返回.通常0代表成功返回,这不是硬性规定,一切要取决于你了.对于用户界面线程,

《Java并发编程》之线程中断与终止线程运行

Java中启动一个线程很容易,通常情况下我们都是等到任务运行结束后让线程自行停止.但有时需要在任务正在运行时取消他们,使得线程快速结束.对此Java并没有提供任何机制.但是我们可以通过Java提供的线程中断机制来实现. 首先来看Thread类三个和中断有关的方法: public class Thread { // 发出一个中断请求,把标志位设定为中断状态,不会终止线程运行. // 其他线程试图调用该方法,会检测是否有权限中断该线程(正常情况 // 下不会存在权限问题,这里可以忽略) public

并发基础(九) java线程的终止与中断

1.简单了解一下:为何不赞成使用 Thread.stop.Thread.suspend 和 Thread.resume? ??suspend .resume.stop方法分别完成了线程的暂停.恢复.终止的工作.不建议使用原因:是因为这三个方法带来的副作用,如suspend( )方法,调用后,线程就会一直占用资源睡眠,直到调用resume( )恢复后,才可以运行.这样很容易引发死锁.同样,stop( )方法在终结一个线程时不会保证线程的资源正常释放,因此会导致程序可能工作在不确定的状态下. ??线

java多线程返回处理结果,并终止所有线程

一.概述 同时并发的按照不同的方式处理数据,需要对处理后的结果在处理或用作响应第三方请求. 这时候,有两种常见的需求. 第一种,只要有一个处理有结果,就立刻结束其他还在运行中的处理方式 第二种,等待所有处理有结果后再处理 二.处理方案 1.线程处理返回结果 一般开发中,使用多线程,最常见的就是:1.实现Runnable接口:2.继承Thread类. 但是run方法是没有返回结果,很难满足我们的需求.这时,常用的办法就是实现Callable接口 Callable接口提供了一个call方法入口,我们

我对java中任务取消和线程中断的一点儿理解

在JDK中任务就是一个Runnable或Callable对象,线程是一个Thread对象,任务是运行在某个线程中的.我们知道,让线程死亡的方式有2种:正常完成和未捕获的异常.如果想让任务结束,也只有这2种方式. java中虽然提供了抢占式中断Thread.stop(),但这是很不安全的,JDK早已经将其标记成过时的了.在java中如果想取消一个任务,只能使用中断,中断是一种协作机制.也就是说,如果A线程想中断B线程,那么其实是A向B发送了一个中断请求,至于B到底会不会停止执行,取决于B的实现.如

【Java并发编程】:线程挂起、恢复与终止

挂起和恢复线程     Thread 的API中包含两个被淘汰的方法,它们用于临时挂起和重启某个线程,这些方法已经被淘汰,因为它们是不安全的,不稳定的.如果在不合适的时候挂起线程(比如,锁定共享资源时),此时便可能会发生死锁条件--其他线程在等待该线程释放锁,但该线程却被挂起了,便会发生死锁.另外,在长时间计算期间挂起线程也可能导致问题. 下面的代码演示了通过休眠来延缓运行,模拟长时间运行的情况,使线程更可能在不适当的时候被挂起: public class DeprecatedSuspendRe

java多线程编程--如何终止一个线程

1. Thread.stop()函数 stop()函数终止线程就像是强行拔掉电源线关机一样,可能会带来未知风险,因此目前不再推荐使用这种方式.请忘记它吧~~ 2. 改变标志变量状态 通常我们会在线程中使用一个标志变量来控制线程的运行,如: public class TestCallable implements Runnable { private boolean running = true; public void stop() { this.running = false; } publi

Java 线程的终止-interrupt

Java线程的终止--interrupt 取消/关闭的场景 我们知道,通过线程的start方法启动一个线程后,线程开始执行run方法,run方法运行结束后线程退出,那为什么还需要结束一个线程呢?有多种情况,比如说: 很多线程的运行模式是死循环,比如在生产者/消费者模式中,消费者主体就是一个死循环,它不停的从队列中接受任务,执行任务,在停止程序时,我们需要一种"优雅"的方法以关闭该线程. 在一些图形用户界面程序中,线程是用户启动的,完成一些任务,比如从远程服务器上下载一个文件,在下载过程

线程的终止stop与线程的中断interrupted

线程除了运行完毕,自动进入死亡状态,也可以手动进行停止,Thread类也提供了2个类方法来进行线程的停止. 一.stop 如图所示,stop方法已经被标记为过时的,不推荐的.因为这这个方法太过于暴力,会立即杀死进程,导致数据不能同步,带来很难排查的错误. 下面是一段造成错误信息的代码: 1 public class StopThreadUnsafe { 2 public static User u = new User(); 3 4 public static class User { 5 pr