浅谈Thread.sleep()为什么要抛出中断异常

从场景说起

假设sleep()方法不抛出中断异常，也就是线程没有中断响应能力，会怎么样？

考虑如下场景：

线程A：sleep中

线程B：A别睡了，要关机啦（向A发送中断信号）

线程A：sleep中

这样好吗？这不好。因为线程A对外界情况没有感知能力。

中断就起到了这样的作用：让线程具有感知的能力。sleep(),wait()等方法都需要你去处理中断异常，也就是需要你的代码能够响应中断。

响应中断

什么叫能够响应中断呢？下面这段最常见的代码可以响应吗？

try {
    Thread.sleep(100);
} catch (Interrupted编程客栈Exception e) {
    e.printStackTrace();
}

答案是可以响应，但还不够。为什么呢？

如下图，官方文档说了：抛异常的同时，该线程的中断状态会被清除。

那中断状态清除了，有什么影响吗？

当然有，我们一般代码都会这样写：（目的：休眠100毫秒后，判断线程是否被中断，如果未被中断则继续执行业务）

try {
    Thread.sleep(100);
} catch (InterruptedException e) {
    //中断标志已经被清除了
}
// Thread.currentThread().isInterrupted():是否被中断了（是否有中断标志）
if(!Thread.currentThread().isInterrupted()) {
    //如果没有被中断，则处理业务
    DOSomething();
}

如果你运行起来会发现，即使线程在sleep期间被中断，我们下面的代码依然会执行。为什么呢？就是因为sleep是会擦除中断标志的。

那你可能会说：我为什么要写if(!Thread.currentThread().isInterruptwww.devze.comed())呢？我平时都不判断的。

首先这是个demo，主要是展示效果。其次，我们任何代码都要有响应中断的能力，所以一般加个while(!Thread.currentThread().isInterrupted())。

回到上面的demo，如果要实现休眠100毫秒后，判断线程是否被中断，如果未被中断则继续执行业务该怎么办？

很简单，我们在本线程再中断一次即可。代码如下：

try {
    Thread.sleep(100);
} catch (InterruptedException e) {
    //中断标志已经被清javascript除了
    // 手动中断本线程，将本线程打上中断信号。
    Thread.currentThread().interrupt();
}
// Thread.currentThread().isInterrupted():是否被中断了（是否有中断标志）
if(!Thread.currentThread().isInterrupted()) {
    //如果没有被中断，则处理业务
    doSomething();
}

如上python述代码所示，我们手动python调用interrupt()方法即可。这样业务代码就不会执行了。

关闭线程池

可能上述理论你还是有些懵。下面进入实战环节。

那么我们看看线程池如何关闭？

有两个API：

void shutdown()：等待队列和当前执行的任务会继续执行完。

List<Runnable> shutdownNow()：对所有正在执行的任务线程发送中断信号。等待队列的任务会被返回。

这下你知道为什么我们代码需要有响应中断的能力了吗？我们先举一个无法停掉线程的例子：

ExecutorService executorService = Executors.newFixedThreadPool(1);
executorService.execute(()->{
    //任开发者_Python入门务一直跑
    while (true) {
        System.out.println("1");
    }
});
 
Thread.sleep(10);
executorService.shutdownNow();

你看，我们根本无法停掉任务，根本无法关闭线程池！

所以while(!Thread.currentThread().isInterrupted())才对嘛。

怎么关呢？代码我就不写了，关键点如下：

1.你的代码一定要有响应中断的能力。

2.sleep等方法就有这个能力。但是他会擦除中断标志位，记得调用Thread.currentThread().interrupt()恢复中断标志位哦。

到此这篇关于浅谈Thread.sleep()为什么要抛出中断异常的文章就介绍到这了,更多相关Thread.sleep()抛出中断异常内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！