更新线程状态,终止

Author: Java-Edge

.idea/inspectionProfiles/Project_Default.xml

@@ -8,7 +8,7 @@
 import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter;
 
 /**
- * @author sss
+ * @author JavaEdge
  */
 @SpringBootApplication
 public class ConcurrencyApplication extends WebMvcConfigurerAdapter{

concurrency/src/main/java/com/javaedge/concurrency/ConcurrencyApplication.java

@@ -9,7 +9,7 @@
 import java.util.concurrent.Semaphore;
 
 /**
- * @author sss
+ * @author JavaEdge
  */
 @Slf4j
 @NotThreadSafe

concurrency/src/main/java/com/javaedge/concurrency/ConcurrencyTest.java

@@ -0,0 +1,75 @@
+package com.javaedge.concurrency.common.state;
+
+/**
+ * 多线程运行状态切换示例
+ *
+ * @author JavaEdge
+ * @date 2019/8/26
+ */
+public class ThreadState {
+    public static Thread thread1;
+    public static ThreadState obj;
+
+    public static void main(String[] args) throws Exception {
+
+        // 第一种状态切换 - 新建 -> 运行 -> 终止
+        System.out.println("=======  第一种状态切换  - 新建 -> 运行 -> 终止  =======");
+
+        Thread thread1 = new Thread(() -> {
+            System.out.println("thread1当前状态：" + Thread.currentThread().getState().toString());
+            System.out.println("thread1 执行");
+        });
+
+        System.out.println("未调用start方法，thread1当前状态：" + thread1.getState().toString());
+
+        thread1.start();
+
+        // 等待thread1执行结束，再看状态
+        Thread.sleep(2000L);
+        System.out.println("等待2s，再看thread1当前状态：" + thread1.getState().toString());
+        // thread1.start(); 线程终止之后，再调用start方法，会抛IllegalThreadStateException
+
+        System.out.println("-------------------------------------");
+        System.out.println("======= 第二种：新建 -> 运行 -> 等待 -> 运行 -> 终止(sleep方式) =======");
+        Thread thread2 = new Thread(() -> {
+            try {
+                // 将线程2移动到等待状态，1500ms后自动唤醒
+                Thread.sleep(1500);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+            System.out.println("thread2当前状态：" + Thread.currentThread().getState().toString());
+            System.out.println("thread2 执行");
+        });
+        System.out.println("未调用start方法，thread2当前状态：" + thread2.getState().toString());
+        thread2.start();
+        System.out.println("调用start方法，thread2当前状态：" + thread2.getState().toString());
+        // 等待200毫秒，再看状态
+        Thread.sleep(200L);
+        System.out.println("等待200毫秒，再看thread2当前状态：" + thread2.getState().toString());
+        // 再等待3秒，让thread2执行完毕，再看状态
+        Thread.sleep(3000L);
+        System.out.println("等待3秒，再看thread2当前状态：" + thread2.getState().toString());
+
+        System.out.println("-------------------------------------");
+        System.out.println("======= 第三种：新建 -> 运行 -> 阻塞 -> 运行 -> 终止 =======");
+        Thread thread3 = new Thread(() -> {
+            synchronized (ThreadState.class) {
+                System.out.println("thread3当前状态：" + Thread.currentThread().getState().toString());
+                System.out.println("thread3 执行了");
+            }
+        });
+        synchronized (ThreadState.class) {
+            System.out.println("未调用start方法，thread3当前状态：" + thread3.getState().toString());
+            thread3.start();
+            System.out.println("调用start方法，thread3当前状态：" + thread3.getState().toString());
+            // 等待200毫秒，再看状态
+            Thread.sleep(200L);
+            System.out.println("等待200毫秒，再看thread3当前状态：" + thread3.getState().toString());
+        }
+        // 再等待3秒，让thread3执行完毕，再看状态
+        Thread.sleep(3000L);
+        System.out.println("等待3秒，让thread3抢到锁，再看thread3当前状态：" + thread2.getState().toString());
+
+    }
+}

concurrency/src/main/java/com/javaedge/concurrency/common/state/ThreadState.java

@@ -0,0 +1,29 @@
+package com.javaedge.concurrency.common.stop;
+
+/**
+ * 通过状态位来判断
+ *
+ * @author JavaEdge
+ * @date 2019/8/29
+ */
+public class FlagStopThread extends Thread {
+    public volatile static boolean flag = true;
+
+    public static void main(String[] args) throws InterruptedException {
+        new Thread(() -> {
+            try {
+                while (flag) { // 判断是否运行
+                    System.out.println("运行中");
+                    Thread.sleep(1000L);
+                }
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+        }).start();
+        // 3秒之后，将状态标志改为False，代表不继续运行
+        Thread.sleep(3000L);
+        flag = false;
+        System.out.println("程序运行结束");
+    }
+}
+

concurrency/src/main/java/com/javaedge/concurrency/common/stop/FlagStopThread.java

@@ -0,0 +1,33 @@
+package com.javaedge.concurrency.common.stop;
+
+/**
+ * 线程stop强制性中止，破坏线程安全的示例
+ *
+ * @author JavaEdge
+ * @date 2019/8/26
+ */
+public class StopThread extends Thread {
+    private int i = 0, j = 0;
+
+    @Override
+    public void run() {
+        synchronized (this) {
+            // 增加同步锁，确保线程安全
+            ++i;
+            try {
+                // 休眠10秒,模拟耗时操作
+                Thread.sleep(10000);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+            ++j;
+        }
+    }
+
+    /**
+     * 打印i和j
+     */
+    public void print() {
+        System.out.println("i=" + i + " j=" + j);
+    }
+}

concurrency/src/main/java/com/javaedge/concurrency/common/stop/StopThread.java

@@ -0,0 +1,26 @@
+package com.javaedge.concurrency.common.stop;
+
+/**
+ * 线程stop强制性中止，破坏线程安全的示例
+ *
+ * @author JavaEdge
+ * @date 2019/8/26
+ */
+public class ThreadStop {
+    public static void main(String[] args) throws InterruptedException {
+        StopThread thread = new StopThread();
+        thread.start();
+        // 休眠1秒，确保i变量自增成功
+        Thread.sleep(1000);
+        // 暂停线程
+        // thread.stop(); // 错误的终止
+        thread.interrupt(); // 正确的终止
+        while (thread.isAlive()) {
+            // 确保线程已经终止
+        } // 输出结果
+        thread.print();
+    }
+}
+
+
+

concurrency/src/main/java/com/javaedge/concurrency/common/stop/ThreadStop.java

@@ -7,7 +7,7 @@
 import org.springframework.web.bind.annotation.ResponseBody;
 
 /**
- * @author sss
+ * @author JavaEdge
  */
 @Controller
 @RequestMapping("/cache")

concurrency/src/main/java/com/javaedge/concurrency/example/cache/CacheController.java

@@ -7,7 +7,7 @@
 import javax.annotation.Resource;
 
 /**
- * @author sss
+ * @author JavaEdge
  */
 @Component
 public class RedisClient {

concurrency/src/main/java/com/javaedge/concurrency/example/cache/RedisClient.java

@@ -6,7 +6,7 @@
 import redis.clients.jedis.JedisPool;
 
 /**
- * @author sss
+ * @author JavaEdge
  */
 @Configuration
 public class RedisConfig {