欢迎来到小居数码网-一家分享数码知识,生活小常识的网站,希望可以帮助到您。

当前位置:生活小常识 > 数码知识 >
优质

java线程自己死掉了(java停止线程)

数码知识

丁谦优秀作者

原创内容 来源:小居数码网 时间:2024-08-16 11:34:01 阅读() 收藏:28 分享:60

导读:您正在阅读的是关于【数码知识】的问题,本文由科普作家协会,生活小能手,著名生活达人等整理监督编写。本文有1892个文字,大小约为8KB,预计阅读时间5分钟。

Java中 终止线程通常意味着在线程处理任务完成之前停掉正在做的操作,也就是放弃当前的操作。

java停止线程

在 Java 中有以下 3 种方法可以终止正在运行的线程:

  • 使用退出标志,使线程正常退出,也就是当 run() 方法完成后线程中止。
  • 使用stop()方法,已被弃用。原因是:stop()是立即终止,会导致一些数据被到处理一部分就会被终止,而用户并不知道哪些数据被处理,哪些没有被处理,产生了不完整的“残疾”数据,不符合完整性,所以被废弃。So, forget it!
  • 使用 interrupt 方法中断线程。注意使用interrupt()方法中断正在运行中的线程只会修改中断状态位,可以通过isInterrupted()判断。如果使用interrupt()方法中断阻塞中的线程,那么就会抛出InterruptedException异常,可以通过catch捕获异常,然后进行处理后终止线程。有些情况,我们不能判断线程的状态,所以使用interrupt()方法时一定要慎重考虑。
  • 使用volatile标志位

    看一个简单的例子:

    首先,实现一个Runnable接口,在其中定义volatile标志位,在run()方法中使用标志位控制程序运行。

    public class MyRunnable implements Runnable {  //定义退出标志,true会一直执行,false会退出循环 //使用volatile目的是保证可见性,一处修改了标志,处处都要去主存读取新的值,而不是使用缓存 public volatile boolean flag = true;  public void run() {  System.out.println("第" + Thread.currentThread().getName() + "个线程创建");    try {   Thread.sleep(1000L);  } catch (InterruptedException e) {   e.printStackTrace();  }    //退出标志生效位置  while (flag) {  }  System.out.println("第" + Thread.currentThread().getName() + "个线程终止"); }}

    然后,在main()方法中创建线程,在合适的时候,修改标志位,终止运行中的线程。

    public class TreadTest { public static void main(String[] arg) throws InterruptedException {  MyRunnable runnable = new MyRunnable();    //创建4个线程  for (int i = 0; i < 4; i++) {   Thread thread=new Thread(myRunable,i+"   ");   thread.start();   }  //线程休眠  Thread.sleep(2000L);  System.out.println("——————————————————————————");  //修改退出标志,使线程终止  runnable.flag = false;  }}

    最后,运行结果,如下:

    使用interrupt()中断的方式

    需要明确的一点的是:interrupt() 方法并不像在 for 循环语句中使用 break 语句那样干脆,马上就停止循环。调用 interrupt() 方法仅仅是在当前线程中打一个停止的标记,并不是真的停止线程。

    也就是说,线程中断并不会立即终止线程,而是通知目标线程,有人希望你终止。至于目标线程收到通知后会如何处理,则完全由目标线程自行决定。这一点很重要,如果中断后,线程立即无条件退出,那么我们又会遇到stop()方法的老问题。

    事实上,如果一个线程不能被 interrupt,那么 stop 方法也不会起作用。

    我们来看一个使用 interrupt() 的例子:

    public class InterruptThread1 extends Thread{    public static void main(String[] args) {        try {            InterruptThread1 t = new InterruptThread1();            t.start();            Thread.sleep(200);            t.interrupt();        } catch (InterruptedException e) {            e.printStackTrace();        }    }    @Override    public void run() {        super.run();        for(int i = 0; i <= 200000; i++) {            System.out.println("i=" + i);        }    }    }

    从输出的结果我们会发现 interrupt 方法并没有停止线程 t 中的处理逻辑,也就是说即使 t 线程被设置为了中断状态,但是这个中断并不会起作用,那么该如何停止线程呢?

    这就需要使用到另外两个与线程中断有关的方法了:

    public boolean Thread.isInterrupted() //判断是否被中断public static boolean Thread.interrupted() //判断是否被中断,并清除当前中断状态

    这两个方法使得当前线程能够感知到是否被中断了(通过检查标志位)。

    所以如果希望线程 t 在中断后停止,就必须先判断是否被中断,并为它增加相应的中断处理代码:

    @Overridepublic void run() {    super.run();    for(int i = 0; i <= 200000; i++) {        //判断是否被中断        if(Thread.currentThread().isInterrupted()){            //处理中断逻辑            break;        }        System.out.println("i=" + i);    }}

    输出结果,for 循环在执行完成前就提前结束了:

    在上面这段代码中,我们增加了 Thread.isInterrupted() 来判断当前线程是否被中断了,如果是,则退出 for 循环,结束线程。

    这种方式看起来与之前介绍的“使用标志位终止线程”非常类似,但是在遇到 sleep() 或者 wait() 这样的操作,我们只能通过中断来处理了。

    public static native void sleep(long millis) throws InterruptedException

    Thread.sleep() 方法会抛出一个 InterruptedException 异常,当线程被 sleep() 休眠时,如果被中断,这会就抛出这个异常。

    注意:Thread.sleep() 方法由于中断而抛出的异常,是会清除中断标记的。

    使用stop()中断

    通过查看 JDK 的 API,我们会看到 java.lang.Thread 类型提供了一系列的方法如 start()、stop()、resume()、suspend()、destory()等方法来管理线程。但是除了 start() 之外,其它几个方法都被声名为已过时(deprecated)。

    虽然 stop() 方法确实可以停止一个正在运行的线程,但是这个方法是不安全的,而且该方法已被弃用,最好不要使用它。

    为什么弃用stop:

    调用 stop() 方法会立刻停止 run() 方法中剩余的全部工作,包括在 catch 或 finally 语句中的,并抛出ThreadDeath异常(通常情况下此异常不需要显示的捕获),因此可能会导致一些清理性的工作的得不到完成,如文件,数据库等的关闭。调用 stop() 方法会立即释放该线程所持有的所有的锁,导致数据得不到同步,出现数据不一致的问题。

    例如,存在一个对象 u 持有 ID 和 NAME 两个字段,假如写入线程在写对象的过程中,只完成了对 ID 的赋值,但没来得及为 NAME 赋值,就被 stop() 导致锁被释放,那么当读取线程得到锁之后再去读取对象 u 的 ID 和 Name 时,就会出现数据不一致的问题,如下图:

    while(true){i++;}死循环是如何跳出的

    @Override    public void run() {        while (true){            try {                /**                 * mBlockingQueue会在线程内声明如下                 * private final BlockingQueue<String> mBlockingQueue;                 * 线程初始化时会对mBlockingQueue赋值                 * */                String string = mBlockingQueue.take();                Log.d("wuyazhouHttp","string: "+string);            } catch (InterruptedException e) {//捕捉异常                if (mQuit) {                    Log.d("wuyazhouHttp","线程结束");                    return;                }                Log.d("wuyazhouHttp","string: 阻塞列表为空");                continue;            }        }    }
    public void quit() {    mQuit = true;//更新标志位    interrupt();//调用interrupt()方法中断阻塞并抛出一个异常}

    首先会更新标志位可以结束线程,其次调用interrupt()方法中断阻塞并抛出一个异常,然后就能调用第二段代码中的return以终止进程

    上面就是小居数码小编今天给大家介绍的关于(java停止线程)的全部内容,希望可以帮助到你,想了解更多关于数码知识的问题,欢迎关注我们,并收藏,转发,分享。

    94%的朋友还想知道的:

    (400)个朋友认为回复得到帮助。

    部分文章信息来源于以及网友投稿,转载请说明出处。

    本文标题:java线程自己死掉了(java停止线程):http://sjzlt.cn/shuma/156078.html

    猜你喜欢