java中使用interrupt通知线程停止详析

更新时间：2022年09月23日 09:22:35 作者：_灯火阑珊处

这篇文章主要介绍了java中使用interrupt通知线程停止详析，文章介绍的是使用interrupt来通知线程停止运行，而不是强制停止，详细内容需要的小伙伴可以参考一下

普通情况停止线程

public class RightWayStopThreadWithoutSleep implements Runnable {

    @Override
    public void run() {
        int num = 0;
        while (!Thread.currentThread().isInterrupted() && num <= Integer.MAX_VALUE / 2) {
            if (num % 10000 == 0) {
                System.out.println(num + "是1W的倍数");
            }
            num++;
        }
        System.out.println("任务运行结束！");
    }

    public static void main(String[] args) throws InterruptedException {
        Thread thread = new Thread(new RightWayStopThreadWithoutSleep());
        thread.start();
        // 等待1s
        Thread.sleep(1000);
        // 通知停止线程
        thread.interrupt();
    }
}

使用 thread.interrupt() 通知线程停止

但是 线程需要配合：

在 while 中使用 Thread.currentThread().isInterrupted() 检测线程当前的状态

运行结果：

……
……
221730000是1W的倍数
221740000是1W的倍数
221750000是1W的倍数
221760000是1W的倍数
221770000是1W的倍数
221780000是1W的倍数
221790000是1W的倍数
221800000是1W的倍数
任务运行结束！

Process finished with exit code 0

在可能被阻塞情况下停止线程

public class RightWayStopThreadWithSleep {
    public static void main(String[] args) throws InterruptedException {
        Runnable runnable = () -> {
            int num = 0;
            while (num <= 300 && !Thread.currentThread().isInterrupted()) {
                if (num % 100 == 0) {
                    System.out.println(num + "是100的倍数");
                }
                num++;
            }
            try {
                // 等个1秒，模拟阻塞
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                System.out.println("线程已停止！！");
                e.printStackTrace();
            }
        };

        Thread thread = new Thread(runnable);
        thread.start();
        // 等待时间要小于上面设置的1秒，不然线程都运行结束了，才执行到下面的thread.interrupt();代码
        Thread.sleep(500);
        // 通知停止线程
        thread.interrupt();
    }
}

线程在sleep 1秒的过程中，收到interrupt信号被打断，

线程正在sleep过程中响应中断的方式就是抛出 InterruptedException 异常

运行结果：

0是100的倍数
100是100的倍数
200是100的倍数
300是100的倍数
线程已停止！！
java.lang.InterruptedException: sleep interrupted
at java.lang.Thread.sleep(Native Method)
at stopthreads.RightWayStopThreadWithSleep.lambda$main$0(RightWayStopThreadWithSleep.java:19)
at java.lang.Thread.run(Thread.java:748)

Process finished with exit code 0

在每次迭代后都阻塞的情况下停止线程

public class RightWayStopThreadWithSleepEveryLoop {
    public static void main(String[] args) throws InterruptedException {
        Runnable runnable = () -> {
            int num = 0;
            try {
                while (num <= 10000) {
                    if (num % 100 == 0) {
                        System.out.println(num + "是100的倍数");
                    }
                    num++;
                    // 每次循环都要等待10毫秒，模拟阻塞
                    Thread.sleep(10);
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        };
        Thread thread = new Thread(runnable);
        thread.start();
        // 5秒后通知停止线程
        Thread.sleep(5000);
        thread.interrupt();
    }
}

当每次迭代都会让线程阻塞一段时间的时候，在 while/for 循环条件判断时，

是不需要使用 *Thread.currentThread().isInterrupted() *判断线程是否中断的

运行结果：

0是100的倍数
100是100的倍数
200是100的倍数
300是100的倍数
400是100的倍数
java.lang.InterruptedException: sleep interrupted

如果将上述代码中的 try/catch 放在 while 循环内：

public class RightWayStopThreadWithSleepEveryLoop {
    public static void main(String[] args) throws InterruptedException {
        Runnable runnable = () -> {
            int num = 0;
            while (num <= 10000) {
                if (num % 100 == 0) {
                    System.out.println(num + "是100的倍数");
                }
                num++;
                try {
                    // 每次循环都要等待10毫秒，模拟阻塞
                    Thread.sleep(10);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        };
        Thread thread = new Thread(runnable);
        thread.start();
        // 5秒后通知停止线程
        Thread.sleep(5000);
        thread.interrupt();
    }
}

运行结果：

0是100的倍数
100是100的倍数
200是100的倍数
300是100的倍数
400是100的倍数
java.lang.InterruptedException: sleep interrupted
at java.lang.Thread.sleep(Native Method)
at stopthreads.RightWayStopThreadWithSleepEveryLoop.lambda$main$0(RightWayStopThreadWithSleepEveryLoop.java:18)
at java.lang.Thread.run(Thread.java:748)
500是100的倍数
600是100的倍数
700是100的倍数
……
……

会发现虽然抛出了异常，但是程序并没有停止，还在继续输出，

即使在 while 条件判断处添加 !Thread.currentThread().isInterrupted() 条件，依然不能停止程序！

原因是

java语言在设计 sleep() 函数时，有这样一个理念：

就是当它一旦响应中断，便会把 interrupt 标记位清除。

也就是说，虽然线程在 sleep 过程中收到了 interrupt 中断通知，并且也捕获到了异常、打印了异常信息，

但是由于 sleep 设计理念，导致 Thread.currentThread().isInterrupted() 标记位会被清除，

所以才会导致程序不能退出。

这里如果要停止线程，只需要在 catch 内再调用一次 interrupt(); 方法

try {
    // 每次循环都要等待10毫秒，模拟阻塞
    Thread.sleep(10);
} catch (InterruptedException e) {
    e.printStackTrace();
    Thread.currentThread().interrupt();
}

所以说，不要以为调用了 interrupt() 方法，线程就一定会停止。

两种停止线程最佳方法

1. 捕获了 InterruptedException 之后的优先选择：在方法签名中抛出异常

public class RightWayStopThreadInProd implements Runnable {

    public static void main(String[] args) throws InterruptedException {
        Thread thread = new Thread(new RightWayStopThreadInProd());
        thread.start();
        Thread.sleep(1000);
        thread.interrupt();
    }
    @Override
    public void run() {
        while (true) {
            System.out.println("go...");
            try {
                throwInMethod();
            } catch (InterruptedException e) {
                // 捕获异常，进行保存日志、停止程序等操作
                System.out.println("stop");
                e.printStackTrace();
            }
        }
    }
    /**
     * 如果方法内要抛出异常，最好是将异常抛出去，由顶层的调用方去处理，而不是try/catch
     * 这样调用方才能捕获异常并作出其它操作
     * @throws InterruptedException
     */
    private void throwInMethod() throws InterruptedException {
        Thread.sleep(2000);
    }
}

如果方法内要抛出异常，最好是将异常抛出去，由顶层的调用方去处理，而不是 try/catch

这样调用方才能捕获异常并做出其它操作。

2. 在 catch 中调用 Thread.currentThread().interrupt(); 来恢复设置中断状态

public class RightWayStopThreadInProd2 implements Runnable {
    public static void main(String[] args) throws InterruptedException {
        Thread thread = new Thread(new RightWayStopThreadInProd2());
        thread.start();
        Thread.sleep(1000);
        thread.interrupt();
    }
    @Override
    public void run() {
        while (true) {
            if (Thread.currentThread().isInterrupted()) {
                System.out.println("程序运行结束");
                break;
            }
            reInterrupt();
        }
    }
    private void reInterrupt() {
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            e.printStackTrace();
        }
    }
}

这里的 if (Thread.currentThread().isInterrupted()) 判断，就是要你的代码有响应中断的能力。

总结

调用 interrupt 方法不一定会中断线程
通知线程停止，线程不会立即停止，而是会在合适的时候停止
代码要有响应中断的能力

到此这篇关于java中使用interrupt通知线程停止详析的文章就介绍到这了,更多相关java interrupt 内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

Java异常架构和异常关键字图文详解
Java异常是Java提供的一种识别及响应错误的一致性机制,下面这篇文章主要给大家介绍了关于Java异常架构和异常关键字的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
2022-05-05
spring是如何实现声明式事务的
这篇文章主要介绍了spring是如何实现声明式事务的,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2021-04-04
SpringBoot中的三种应用事件处理机制详解
在项目开发中,组件间的松耦合设计至关重要,应用事件处理机制作为观察者模式的一种实现,允许系统在保持模块独立性的同时实现组件间的通信,SpringBoot延续并增强了Spring框架的事件机制,提供了多种灵活的事件处理方式,本文给大家介绍了SpringBoot中的三种应用事件处理机制
2025-04-04
java实现http的Post、Get、代理访问请求
这篇文章主要为大家提供了java实现http的Post、Get、代理访问请求的相关代码，感兴趣的小伙伴们可以参考一下
2016-01-01
SpringCloud链路追踪组件Sleuth配置方法解析
这篇文章主要介绍了SpringCloud链路追踪组件Sleuth配置方法解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-03-03
Java多线程的实现方式详解
这篇文章主要介绍了Java多线程的实现方式详解,线程就是进程中的单个顺序控制流,也可以理解成是一条执行路径,java中之所以有多线程机制,目的就是为了提高程序的处理效率,需要的朋友可以参考下
2023-08-08
Java中的取余与取模运算概念、区别代码实践
这篇文章主要介绍了Java中的取余与取模运算概念、区别代码实践,需要的朋友可以参考下
2007-02-02
Spring注解实现自动装配过程解析
这篇文章主要介绍了Spring注解实现自动装配过程解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-03-03
一文带你学会Java中ScheduledThreadPoolExecutor使用
ScheduledThreadPoolExecutor是Java并发包中的一个类,同时也是 ThreadPoolExecutor的一个子类,本文主要为大家介绍一下ScheduledThreadPoolExecutor使用,需要的可以参考下
2024-12-12
Java枚举类型enum的详解及使用
这篇文章主要介绍了Java枚举类型enum的详解及使用的相关资料,需要的朋友可以参考下
2017-05-05