Java 线程的终止与线程中断

关于线程终止:

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

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

 一、线程的终止

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

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

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

id=1
id=2

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

看图来说明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;
    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 + ",]";
    }
}

执行结果:

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

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

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/5c9ed1ffb6e7925ebcdeebf6da5b7d5b.html