java中线程中断的实现示例

更新时间：2023年09月07日 09:03:30 作者：Michael_lcf

中断只是一种协作协商机制,Java没有给中断增加任何语法,中断的过程完全需要程序员自己实现,本文就来介绍一下线程中断的实现,具有一定的参考价值,感兴趣的可以了解一下

1、线程中断即线程的取消/关闭的机制

Java中停止一个线程的主要机制是中断，中断并不是强迫终止一个线程，它是一种 协作机制 ，是给线程传递一个取消/关闭信号，由线程自身来决定如何以及何时退出。

停止线程，但这个方法被标记为了过时。
@Deprecated
public final void stop()
=========================
返回对应线程的中断标志位是否为true。
public boolean isInterrupted()
返回当前线程的中断标志位是否为true，并清空中断标志位。
public static boolean interrupted()
表示中断对应的线程。
public void interrupt()

2、线程对中断interrupt()的反应

2.1、RUNNABLE：线程在运行或具备运行条件只是在等待操作系统调度

举个栗子：

public static void main(String[] args) throws InterruptedException {
    Thread t = new Thread(() -> {
        while (!Thread.currentThread().isInterrupted()) {
            System.out.println("线程t 执行中...");
        }
    });
    t.start();
    Thread.sleep(1);
    t.interrupt();
    System.out.println("main exit");
}

RUNNABLE状态的线程t被interrupt()后，是否终止中断线程由线程t自身代码逻辑决定。

2.2、WAITING/TIMED_WAITING：线程在等待某个条件或超时

线程执行如下方法会进入WAITING状态：
public final void join() throws InterruptedException
public final void wait() throws InterruptedException
线程执行如下方法会进入TIMED_WAITING状态：
public final native void wait(long timeout) throws InterruptedException
public static native void sleep(long millis) throws InterruptedException
public final synchronized void join(long millis) throws InterruptedException

举个栗子：

public class ThreadInterrupt {
    public static void main(String[] args) {
        Thread t = new Thread(() -> {
            try {
                Thread.sleep(10000);
            } catch (InterruptedException e) {
                System.out.println("Thread.interrupted() = " + Thread.interrupted());
                //Thread.interrupted() = false
                System.out.println("Thread.interrupted() = " + Thread.interrupted());
                //Thread.interrupted() = false
            }
        });
        t.start();
        t.interrupt();
    }
}

捕获到InterruptedException，通常表示希望结束该线程，线程大概有两种处理方式：
向上传递该异常，这使得该方法也变成了一个可中断的方法，需要调用者进行处理。

有些情况，不能向上传递异常，比如Thread的run方法，它的声明是固定的，不能抛出任何受检异常，这时，应该捕获异常，进行合适的清理操作，清理后，一般应该调用Thread的interrupt方法设置中断标志位，使得其他代码有办法知道它发生了中断。

2.3、BLOCKED：线程在等待锁，试图进入同步块

举个栗子：

public class ThreadInterrupt {
    private final static Object lockObj = new Object();
    private static class MyBlockedThread extends Thread {
        @Override
        public void run() {
            System.out.println("MyBlockedThread.run = " + Thread.currentThread().isInterrupted());
            synchronized (lockObj) {
                while (!Thread.currentThread().isInterrupted()) {
                    System.out.println(Thread.currentThread().isInterrupted());
                }
            }
            System.out.println("exit");
        }
    }
    public static void main(String[] args) throws InterruptedException {
        synchronized (lockObj) {
            MyBlockedThread myBlockedThread = new MyBlockedThread();
            myBlockedThread.start();
            Thread.sleep(3000);
            myBlockedThread.interrupt();
            myBlockedThread.join(); // join方法会等待线程执行完后返回
        }
    }
}

myBlockedThread.join();该行代码放开注释掉情况下：线程一直等待锁 BLOCKED。

com.michael.ThreadInterrupt.MyBlockedThread.run = false

myBlockedThread.join();该行代码注释掉情况下：因为主线程不再等待线程myBlockedThread结束，释放锁lock后，线程myBlockedThread会获得锁，然后检测到发生了中断，然后程序退出。

com.michael.ThreadInterrupt.MyBlockedThread.run = false
exit

2.4、NEW/TERMINATED：线程还未启动或已结束

举个栗子：

public static void main(String[] args) throws InterruptedException {
    Thread t = new Thread(() -> {
        System.out.println("线程t 执行...");
    });
    t.interrupt();
    System.out.println("NEW = " + t.isInterrupted());
    t.start();
    Thread.sleep(100);
    t.interrupt();
    System.out.println("TERMINATE = " + t.isInterrupted());
}
============ 执行结果 ============
NEW = false
线程t 执行...
TERMINATE = false

2.5、IO操作

如果线程在等待IO操作，尤其是网络IO，则会有一些特殊的处理。

如果IO通道是可中断的，即实现了InterruptibleChannel接口，则线程的中断标志位会被设置，同时线程会收到异常ClosedByInterruptException。
如果线程阻塞于Selector调用，则线程的中断标志位会被设置，同时阻塞的调用会立即返回。
InputStream的read调用，该操作是不可中断的，如果流中没有数据，read会阻塞 (但线程状态依然是RUNNABLE)，且不响应interrupt()，与synchronized类似，调用interrupt()只会设置线程的中断标志，而不会真正"中断"。

3、关于中断的经验

Java中取消/关闭线程技术是中断，但它是一种协作机制，不会强制终止线程。线程在不同状态和IO操作时对中断的反应有所不同。
作为线程的实现者：应该提供明确的取消/关闭方法，并用文档描述清楚其行为。
作为线程的调用者：应该使用其取消/关闭方法，而不是贸然调用interrupt()方法。

到此这篇关于java中线程中断的实现示例的文章就介绍到这了,更多相关java 线程中断内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

Java中HashMap集合的6种遍历方式详解
这篇文章主要介绍了Java中HashMap集合的6种遍历方式详解,HashMap 基于哈希表的 Map 接口实现,是以 key-value 存储形式存在,即主要用来存放键值对,HashMap 的实现不是同步的,这意味着它不是线程安全的,我们来看一下其遍历方式,需要的朋友可以参考下
2023-12-12
SpringBoot用配置影响Bean加载@ConditionalOnProperty
这篇文章主要为大家介绍了SpringBoot用配置影响Bean加载@ConditionalOnProperty示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-04-04
Spring Bean生命周期之Bean的注册详解
这篇文章主要为大家详细介绍了Spring Bean生命周期之Bean的注册，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下，希望能够给你带来帮助
2022-03-03
java servlet结合Oracle搭建java的web开发环境
今天我将与大家分享一下我学JAVA WEB写的一些小实例，我个人是不太喜欢书本上的晦涩的概念的，所以我花了更多的时间在一些应用实例上，我觉得这样的学习方式很适合我，由简到繁，由浅入深
2015-12-12
SpringBoot返回对象时,如何将Long类型转换为String
这篇文章主要介绍了SpringBoot返回对象时,实现将Long类型转换为String，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-06-06
spring boot 项目中使用thymeleaf模板的案例分析
这篇文章主要介绍了spring boot 项目中使用thymeleaf模板的案例分析,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2020-09-09
java九种分布式ID解决方案
在日常的业务开发中,通常需要对一些数据做唯一标识,本文主要介绍了java九种分布式ID解决方案,具有一定的参考价值,感兴趣的可以了解一下
2023-09-09
Java @Deprecated注解的作用及传递性
用 @Deprecated注解的程序元素，不鼓励程序员使用这样的元素，通常是因为它很危险或存在更好的选择，本文给大家介绍java @deprecated注解的作用及传递性，对本文感兴趣的朋友一起学习吧
2015-12-12
SpringBoot实现热部署的方式总结
所谓热部署，就是在应用正在运行的时候升级软件，却不需要重新启动应用，对于Java来说，热部署就是在运行时更新Java类文件，本文将深入探讨SpringBoot有哪些方式可以实现热部署，感兴趣的朋友可以小编一探讨学习
2023-06-06
一文搞懂Java中的注解和反射
这篇文章主要给大家介绍了关于Java中注解和反射的原理及使用，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2022-06-06