并发编程

Author: xiaolyuh123

spring-boot-student-concurrent/src/main/java/com/xiaolyuh/DaemonThread.java

@@ -0,0 +1,34 @@
+package com.xiaolyuh;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+
+/**
+ * 守护线程
+ *
+ * @author yuhao.wang3
+ */
+public class DaemonThread {
+
+    public static void main(String[] args) throws InterruptedException {
+        Thread thread = new Thread(() -> {
+            try {
+                while (!Thread.currentThread().isInterrupted()) {
+                    System.out.println(Thread.currentThread().getName()
+                            + " 任务执行 " + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss_SSS")));
+                    Thread.sleep(50);
+                }
+                System.out.println(Thread.currentThread().getName()
+                        + " 任务中断 " + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss_SSS")));
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+                Thread.currentThread().interrupt();
+            } finally {
+                System.out.println("...........finally");
+            }
+        });
+        thread.setDaemon(true);
+        thread.start();
+        Thread.sleep(500);
+    }
+}

spring-boot-student-concurrent/src/main/java/com/xiaolyuh/HasInterrputException.java

@@ -0,0 +1,36 @@
+package com.xiaolyuh;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+
+/**
+ * 中断线程有异常
+ *
+ * @author yuhao.wang3
+ */
+public class HasInterrputException {
+    public static void main(String[] args) throws InterruptedException {
+        Thread thread = new Thread(() -> {
+            String threadName = Thread.currentThread().getName();
+            while (!Thread.currentThread().isInterrupted()) {
+                try {
+                    System.out.println("thread:" + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss_SSS")));
+                    Thread.sleep(3000);
+                } catch (InterruptedException e) {
+                    System.out.println(threadName + " catch interrput flag is " + Thread.currentThread().isInterrupted() +
+                            " at " + (LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss_SSS"))));
+                    Thread.currentThread().interrupt();
+                    e.printStackTrace();
+                }
+                System.out.println(threadName);
+            }
+            System.out.println(threadName + " interrput flag is " + Thread.currentThread().isInterrupted());
+        });
+        thread.start();
+        System.out.println("Main:" + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss_SSS")));
+        Thread.sleep(800);
+        System.out.println("Main begin interrupt thread:" + LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss_SSS")));
+        thread.interrupt();
+    }
+
+}

spring-boot-student-concurrent/src/main/java/com/xiaolyuh/MainThread.java

@@ -0,0 +1,23 @@
+package com.xiaolyuh;
+
+import java.lang.management.ManagementFactory;
+import java.lang.management.ThreadInfo;
+import java.lang.management.ThreadMXBean;
+
+/**
+ * @author yuhao.wang
+ */
+public class MainThread {
+
+    public static void main(String[] args) {
+        //虚拟机线程管理的接口
+        ThreadMXBean threadMXBean = ManagementFactory.getThreadMXBean();
+        ThreadInfo[] threadInfos =
+                threadMXBean.dumpAllThreads(false, false);
+
+        for(ThreadInfo threadInfo:threadInfos) {
+            System.out.println("["+threadInfo.getThreadId()+"]"+" "
+                    +threadInfo.getThreadName());
+        }
+    }
+}