美文网首页
java线程中断原理

java线程中断原理

作者: someoneYoung | 来源:发表于2019-01-17 19:40 被阅读59次

    稍有java基础的同学都知道,在java中创建并启动一个线程比较容易,而线程中断的难度更高一些,并且使用的场景也相对较少。

    interrupt()

    中断某一个线程需要调用该线程对象的interrupt方法。

    public class Demo {
        public static void main(String[] args) {
            Thread thread = new Thread(new MyTask());
            thread.start();
            try {
                Thread.sleep(1000);
            } catch (Exception ex) {
            }
            thread.interrupt();
        }
        static class MyTask implements Runnable {
            @Override
            public void run() {
                while (true) {
                    System.out.println(Thread.currentThread() + " is running...");
                }
            }
        }
    }
    

    运行代码会发现,即使在主线程中执行目标线程的interrupt()方法,但目标线程并没有停止执行。这正是interrupt机制设计的特别之处,当主线程发起目标线程中断的命令后,目标线程并不会立即放弃线程的执行权。

    中断标志位

    java interrupt中断机制是当主线程向目标线程发起interrupt中断命令后,目标线程的中断标志位被置为true,目标线程通过查询中断标志位自行决定是否停止当前线程的执行。
    这便解释了上面的代码中,目标线程的中断标志位虽然置为true,但由于并没有主动采取线程停止的操作,所以线程依然处于Running状态。
    查询线程中断标志位的方法有两种:isInterrupted()和interrupted(),下面分别介绍二者的区别。

    isInterrupted()与interrupted()

    public static boolean interrupted() {
        return currentThread().isInterrupted(true);
    }
    
    public boolean isInterrupted() {
        return isInterrupted(false);
    }
    
    private native boolean isInterrupted(boolean ClearInterrupted);
    

    直接看这两个方法的源码,interrupted()是静态方法而isInterrupted()是实例方法,他们的实现都是调用同一个native方法。主要的区别是他们的形参ClearInterrupted传的不一样。interrupted()在返回中断标志位后会清除标志位,isInterrupted()则不清除中断标志位。
    接下来改造前面的代码,实现线程中断效果:

    public class Demo {
    
        public static void main(String[] args) {
            Thread thread = new Thread(new MyTask());
            thread.start();
            try {
                Thread.sleep(100);
            } catch (Exception ex) {
            }
            thread.interrupt();
        }
    
        static class MyTask implements Runnable {
            @Override
            public void run() {
                while (true) {
                    if (Thread.interrupted()) {
                        break;
                    }
                    System.out.println(Thread.currentThread() + " is running...");
                }
                System.out.println("当前中断标志位状态:" + Thread.currentThread().isInterrupted());
            }
        }
    }
    
    image.png

    InterruptedException

    调用Thread.sleep()时都需要捕获InterruptedException异常。这个异常的作用是什么?
    如果目标线程正在执行阻塞方法(sleep、join),而其他线程恰好调用了目标线程的interrupt方法试图中断目标线程,sleep、join这类阻塞方法会检查线程的中断标志位,并抛出InterruptedException异常。

    阻塞方法为何抛出InterruptedException

    @Override
    public void run() {
        while (true) {
            if (Thread.interrupted()) {
                break;
            }
            // point 1 : 阻塞方法前逻辑
            try {
                // point 2 : 阻塞方法中
                Thread.sleep(10*000*000);
            } catch(InterruptedException ex) {
                // 执行清除逻辑
            }
            // point 3 :阻塞方法后逻辑
        }
    }
    

    前文提到过,interrupt的线程中断机制是由发起线程将目标线程的中断标志位置为true,至于是否执行线程的中断由目标线程决定。
    以上面代码为例,如果目标线程正在执行sleep方法而线程阻塞,必须在10000000时间完成且并执行完后续逻辑,直至循环里下次interrupted()判断后才能中断线程。显然这不是我们希望看到的,所以阻塞方法会判断中断标志位,一旦出现中断的命令就会抛出异常,直接终止阻塞逻辑。

    InterruptedException清空中断标志位

    抛出InterruptedException异常也会清除中断标志位,如果想要继续保留中断标志位的状态,可以手动触发中断标志,代码如下:

    try {
      Thread.sleep(100);
    } catch (InterruptedException ex) {
      Thread.currentThread().interrupt(); 
      throw new RuntimeException(ex);
    }
    

    总结

    要想理解java线程中断的原理,重点就是要掌握中断标志位的使用细节,其他的逻辑都是围绕中断标志位设计。

    相关文章

      网友评论

          本文标题:java线程中断原理

          本文链接:https://www.haomeiwen.com/subject/xdtwdqtx.html