✨ Introducing new features. 线程响应中断

crossoverJie · crossoverJie · commit 0f422d727f63 · 2018-03-16T02:15:52.000+08:00
diff --git a/MD/concurrent/thread-communication.md b/MD/concurrent/thread-communication.md
@@ -291,6 +291,40 @@ CountDownLatch 也是基于 AQS(AbstractQueuedSynchronizer) 实现的，更多
 
 ## 线程响应中断
 
+```java
+public class StopThread implements Runnable {
+    @Override
+    public void run() {
+
+        while ( !Thread.currentThread().isInterrupted()) {
+            // 线程执行具体逻辑
+            System.out.println(Thread.currentThread().getName() + "运行中。。");
+        }
+
+        System.out.println(Thread.currentThread().getName() + "退出。。");
+
+    }
+
+    public static void main(String[] args) throws InterruptedException {
+        Thread thread = new Thread(new StopThread(), "thread A");
+        thread.start();
+
+        System.out.println("main 线程正在运行") ;
+
+        TimeUnit.MILLISECONDS.sleep(10) ;
+        thread.interrupt();
+    }
+
+
+}
+```
+
+可以采用中断线程的方式来通信，调用了 `thread.interrupt()` 方法其实就是将 thread 中的一个标志属性置为了 true。
+
+并不是说调用了该方法就可以中断线程，如果不对这个标志进行响应其实是没有什么作用的(这里对这个标志进行了判断)。
+
+但是如果抛出了 InterruptedException 异常，该标志就会被 JVM 重置为 false。
+
 ## 线程池 awaitTermination() 方法
 
 ## 管道通信
diff --git a/src/main/java/com/crossoverjie/concurrent/StopThread.java b/src/main/java/com/crossoverjie/concurrent/StopThread.java
@@ -0,0 +1,36 @@
+package com.crossoverjie.concurrent;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * Function:
+ *
+ * @author crossoverJie
+ *         Date: 16/03/2018 01:41
+ * @since JDK 1.8
+ */
+public class StopThread implements Runnable {
+    @Override
+    public void run() {
+
+        while ( !Thread.currentThread().isInterrupted()) {
+            // 线程执行具体逻辑
+            System.out.println(Thread.currentThread().getName() + "运行中。。");
+        }
+
+        System.out.println(Thread.currentThread().getName() + "退出。。");
+
+    }
+
+    public static void main(String[] args) throws InterruptedException {
+        Thread thread = new Thread(new StopThread(), "thread A");
+        thread.start();
+
+        System.out.println("main 线程正在运行") ;
+
+        TimeUnit.MILLISECONDS.sleep(10) ;
+        thread.interrupt();
+    }
+
+
+}
