当然是为了让你的代码具有响应中断信号的能力！

目录

从场景说起

响应中断

关闭线程池

从场景说起

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

考虑如下场景：

线程A：sleep中

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

线程A：sleep中

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

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

响应中断

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

try {
    Thread.sleep(100);
} catch (InterruptedException e) {
    e.printStackTrace();
}

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

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

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

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

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

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

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

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

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

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

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

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

关闭线程池

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

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

有两个API：

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

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

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

ExecutorService executorService = Executors.newFixedThreadPool(1);
executorService.execute(()->{
	//任务一直跑
	while (true) {
		System.out.println("1");
	}
});

Thread.sleep(10);
executorService.shutdownNow();

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

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

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

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

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

结合此篇文章进行阅读：InterruptedExcption详细分析

导入：

Thread.sleep()抛的是InterruptedException，这个错误在源码中的注释为：

* Thrown when a thread is waiting, sleeping, or  otherwise occupied,

* and the thread is interrupted, either before or  during the activity.

* Occasionally a method may wish to test whether  the current

* thread has been interrupted, and if so, to  immediately throw

* this exception.

概述：

这个问题实际上是对interrupt方法的一个升级版，先解释interrupt，再解释源码中的判断

源码分析：

通过查看sleep的源码发现，它其实是一个native方法，参考前面run与start区别，来进行源码查找与分析

jvm源码：

http://hg.openjdk.java.net/jdk8u/jdk8u/hotspot/file/111b95ad4584/src/share/vm/prims/jvm.cpp

Thread中native方法的源码，调用了JVM_Sleep方法：

http://hg.openjdk.java.net/jdk8u/jdk8u/jdk/file/f0b93fbd8cf8/src/share/native/java/lang/Thread.c

可以看到，sleep这个方法在源码中是会判断当前进程是否处于interrupted状态的，也符合之前所所说的interrupt方法需要调用的线程支持