Java 多线程-如何正确的中断线程

  在学习Java的过程中,多线程一直以来就是Java中的比较难的知识点,但是多线程又是那么的重要。在实际的开发中,多线程也是常见的。本文将介绍在多线程中怎么正确的中断线程,不会介绍多线程的基知识。

1. 前言

  在Java的线程中,只有线程的run方法运行完毕,才算线程真正的结束。通常来说,一种情况是run方法正确无误的运行完毕,还有一种情况是在run方法里面抛出了异常并且没有捕获,导致线程异常终止。
  在早期的Java版本中,有一个stop方法,可以终止一个线程。但是这个方法已经被弃用了。
  在现如今的Java版本中,没有强制终止线程的方法。然而,我们可以通过interrupt方法来请求终止线程,这个操作需要程序员自己来实现。接下来会介绍interrupt方法的用法。
  当我们对一个线程调用interrupt方法时,线程有一个中断状态标志位将会被重置。这个标志位每一个线程都有。我们在构建自己的多线程时,应该时不时的检查这个标志位,以判断当前线程是否需要终止。
  例如:

    @Override
    public void run() {
        while (true) {
            if (Thread.currentThread().isInterrupted()) {//中断状态标志位被重置
                //退出死循环,结束run方法
                break;
            } else { //没有被重置
                //do your work
            }

        }
    }

  这里我举了一个简单的例子。我们在run方法中增加了一个判断条件,只有当前的中断标志位为false才进行运行的,否则就跳出死循环,此时当前的线程生命就就结束了。此时,如果我们在其他线程里面想要中断这个线程,只需要调用interrupt方法就行了。

2. InterruptException异常产生的原因

  关于InterruptException异常,只要熟悉多线程的朋友可能都会认识,当我们在调用Thread.sleep方法时,就会抛出这个异常,这里将介绍InterruptException异常的原因,并且将介绍这个异常造成的结果。
  前面我们已经知道了,我们可以调用interrupt方法来重置当前线程的中断状态标志位。但是我们在调用这个方法,有一个问题,如果当前的线程被阻塞了(线程的阻塞方式有很多, 比如,被Scanner阻塞,sleep,wait),是无法检测到中断状态,如果此时调用interrupt方法,在阻塞的位置会抛出一个异常,那就是InterruptException异常。这个也能解释,为什么我们在调用sleep方法时,会抛出InterruptException方法。如果线程产生了InterruptException异常,会被异常中断(也存在不能被中断的线程阻塞,比如IO访问)。

3. sleep方法的正确使用

  由于sleep方法会抛出InterruptException异常,所以在一个线程如何使用sleep方法就变得格外不一样。为什么不一样呢?可能各位朋友会这样写代码:

        Thread thread = new Thread(() -> {
            while (true) {
                try {
                    Thread.sleep(500);
                    // 这里的线程工作就是不断打印1
                    System.out.println(1);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                if(Thread.currentThread().isInterrupted()) {
                    break;
                }
            }
        });

  这个代码通常来说没有人写,这里只是为了举一个例子。这个代码感觉是没有任何的问题,如果此时,我们这样调用的话:

        thread.start();
        thread.interrupt();

  那么会出现一个奇怪的现象,就是我们调用interrupt方法,线程不会停止。这个又是什么原因呢?我们先按照常规的思维来思考一下:调用start方法线程开启,先sleep,此时外部调用interrupt方法来重置中断状态标志位,将flag(假设为中断状态标志位)重置为true,但是此时会抛出一个InterruptException,这个的原因,我们在之前已经说了,当前的线程被sleep方法阻塞了,此时如果在调用当前的interrupt方法,会抛出异常。抛出异常之后,进入catch,这个没的说,此时再进入if判断语句,如果当前的flag为true,就会退出循环。
  实际上,在整个过程中,线程被sleep方法阻塞了,但是产生了InterruptException异常时,此时线程不会继续睡眠,而是马上抛出异常,而且会清除flag的状态,也就是将flag变为false。
  我们建议这样做:

        Thread thread = new Thread(() -> {
            try {
                while (true) {
                    Thread.sleep(500);
                    // 这里的线程工作就是不断打印1
                    System.out.println(1);
                    if (Thread.currentThread().isInterrupted()) {
                        break;
                    }
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

友情链接更多精彩内容