【Java|多线程与高并发】线程的中断的两种方法-阿里云开发者社区

【Java|多线程与高并发】线程的中断的两种方法

2023-08-07 123

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 线程中断是指在一个线程执行的过程中，强制终止该线程的执行。虽说是中断,但本质上是让run方法快点执行完,而不是run方法执行到一半,强制结束.

1.前言

线程中断是指在一个线程执行的过程中，强制终止该线程的执行。虽说是中断,但本质上是让run方法快点执行完,而不是run方法执行到一半,强制结束.

本文主要介绍线程中断的两种方法

2. 方法1: 自定义标志位

看下面这段代码:

public class Demo6 {
    private static boolean flag = false;
    public static void main(String[] args) {
        Thread t = new Thread(()->{
            while(!flag){
                System.out.println("线程执行中!");
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
            }
            System.out.println("线程执行完了!");
        });
        t.start();
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        System.out.println("设置标志位,让线程执行结束");
        flag = true;
    }
}

运行结果:

看下面这张图:

在这段代码中,定义了一个flag的标志位,在线程t中以标志位作为run方法的执行条件,每隔1s输出一次"线程执行中",再先让main线程(主线程)休眠3s,3s后main线程开始执行,输出"设置标志位,让线程执行结束",并修改flag变量的值为false,线程t不满足执行条件,因此线程t执行完毕.

3. 方法2:使用标准库自带的标志位

Java提供了一种中断线程的机制，即调用线程的interrupt()方法。

当一个线程被中断时，它会收到一个中断信号，但并不意味着线程会立即停止执行。线程可以通过检查自己的中断状态来决定是否停止执行。线程可以通过调用isInterrupted()方法来检查自己是否被中断。如果线程已经被中断，那么该方法返回true，否则返回false。

示例:

public class Demo7 {
    public static void main(String[] args) {
        Thread t = new Thread(()->{
            while(!Thread.currentThread().isInterrupted()){
                System.out.println("线程执行中!");
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            System.out.println("线程执行完了!");
        });
        t.start();
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        System.out.println("设置标志位,让线程执行结束");
        t.interrupt();
    }
}