想到关闭线程首先会想到 Thead 类的 stop() 方法，但是该方法已经被标记为 @Deprecated 已过时，虽然它确实可以停止一个正在运行的线程，但是这个方法是不安全的，并且在将来的Java版本中这个方法将不可用或不被支持，具体 stop() 的不好的地方，本次不再赘述。
本次主要讲解 interrupt()、interrupted()、isInterrupted() 三者的区别和关系，以及如何使用更优雅的方式去中断一个正在执行的线程
1：中断相关Thread API
1.1：interrupt() 方法
public void interrupt () { ... }
根据方法签名可以看出该方法是
Thread的 对象方法，并非是Thread的静态方法。interrupt有 中断, 阻断 的意思，但是它并没有 中止线程 的能力，可以理解为线程的一个标识位属性或者说在当前线程中打了一个停止标记例如：A线程正在运行，B线程 持有 A线程对象 的引用 (eg：aThead)，如果 B线程 调用 A线程对象 的interrupt () 方法：aThead.interrupt()，此时 A线程 依然会运行，除非 A线程 检查到自己被别人要求中断，然后尽快的结束run()方法，此时线程才会被中断。如何检查自己有没有被别人中断呢？
1.2：Thread.interrupted() 方法
public static boolean interrupted() {
// true 表示清除 '状态标志'
return currentThread().isInterrupted(true);
}
- 通过源码可以看出，该方法是
Thread类的静态方法 - 检查
当前线程！！！是否已经中断，返回true表示已经被中断 - 执行该方法后会将
状态标志清除为false
public static void main(String[] args) {
Thread.currentThread().interrupt();
System.out.println("是否终止：" + Thread.interrupted()); // 是否终止：true
System.out.println("是否终止：" + Thread.interrupted()); // 是否终止：false
}
通过main方法的执行，可以得到两个一下几个结论：
（1）interrupt ()方法 不会停止正在运行的线程
（2）Thread.interrupted() 方法，可以检查 当前线程是否中断
（3）调用该方法在会清除当前线程的 状态标志 为 false
1.3：isInterrupted() 方法
public boolean isInterrupted() {
// false 表示不清除 '状态标志'
return isInterrupted(false);
}
- 该方法是
Thread的 对象方法，并非是Thread的静态方法。 - 测试线程对象是否已经中断
- 不清除 '状态标志'
public static void main(String[] args) {
Thread mainThread = Thread.currentThread();
mainThread.interrupt();
System.out.println("是否终止：" + mainThread.isInterrupted()); // 是否终止：true
System.out.println("是否终止：" + mainThread.isInterrupted()); // 是否终止：true
}
2：如何优雅安全的终止进程
2.1：使用interrupt()方法终止线程
public static void main(String[] args) throws InterruptedException {
// 创建线程
Thread thread = new Thread(() -> {
while (true) {
// 自身判断线程是否被别的线程中断
if (Thread.currentThread().isInterrupted()) {
break;
}
System.out.println(Thread.currentThread().getName() + "：Hello");
}
}, "thread_1");
// 开启线程（通知"线程规划器 分配新的线程执行run方法"）
thread.start();
// main 线程睡 100ms
Thread.sleep(100);
// 中断 子线程
thread.interrupt();
}
执行结果：
2.2：使用退出标记退出线程
public class StopFlagDemo implements Runnable {
private volatile boolean shutdown = false;
private long count;
public static void main(String[] args) throws InterruptedException {
// 创建线程任务
StopFlagDemo runTask = new StopFlagDemo();
// 开启线程（通知"线程规划器 分配新的线程执行run方法"）
Thread childThread = new Thread(runTask, "childThread");
childThread.start();
// main 线程睡 100ms
Thread.sleep(100);
// 中断 子线程
runTask.close();
}
/**
* 线程任务
*/
@Override
public void run() {
while (true) {
if (this.shutdown) {
break;
}
System.out.println(Thread.currentThread().getName() + "：" + (count++));
}
}
/**
* 终止线程
*/
public void close() {
this.shutdown = true;
}
}
执行结果：
3：关于 InterruptedException的说明
我们发现在 Thread.sleep() 的时候都会抛出一个检查异常 InterruptedException
public static native void sleep(long millis) throws InterruptedException;
当外部 线程A 持有 线程B 的线程对象，并调用了B对象的interrupt()方法bThread.interrupt()，如果B线程中后续会有Thread.sleep()或者正在sleep()的时候，会抛出 InterruptedException 异常，其实在抛出异常之前，JVM会将该线程的中断状态清除，此时获取线程中断状态标志返回false
public static void main(String[] args) throws InterruptedException {
// 创建线程
Thread thread = new Thread(() -> {
try {
for (int i = 0; i < 100000; i++) {
System.out.println(i + 1);
}
while (true) {
Thread.sleep(1000);
}
} catch (InterruptedException e) {
System.out.println("当前状态标记: " + Thread.currentThread().isInterrupted());
e.printStackTrace();
}
}, "thread_1");
thread.start();
// 如果不加该睡眠：验证 "中断"发生在子线程sleep【前】会不会抛异常（会）
// 如果加该睡眠：验证 "中断"发生在子线程sleep【中】是否会抛异常（会）
// Thread.sleep(2000);
thread.interrupt();
}
执行结果：
最后
如果有任何不对的地方欢迎指正，感谢~
