更新线程池测试用例代码

Author: Java-Edge

concurrency/src/main/java/com/javaedge/concurrency/common/closure/ThreadClosure.java

@@ -0,0 +1,45 @@
+package com.javaedge.concurrency.common.closure;
+
+import org.testng.annotations.Test;
+
+
+/**
+ *
+ * @author JavaEdge
+ * @date 2019/10/9
+ */
+public class ThreadClosure {
+
+    /**
+     * threadLocal变量，每个线程都有一个副本，互不干扰
+     */
+    public static ThreadLocal<String> value = new ThreadLocal<>();
+
+    @Test
+    public void threadLocalTest() throws Exception {
+
+        // 主线程设值
+        value.set("这是主线程设置的123");
+        String v = value.get();
+        System.out.println("线程1执行之前，主线程取到的值：" + v);
+
+        new Thread(() -> {
+            String v1 = value.get();
+            System.out.println("线程1取到的值：" + v1);
+            // 设置 threadLocal
+            value.set("这是线程1设置的456");
+
+            v1 = value.get();
+            System.out.println("重新设置之后，线程1取到的值：" + v1);
+            System.out.println("线程1执行结束");
+        }).start();
+
+        // 等待所有线程执行结束
+        Thread.sleep(5000L);
+
+        v = value.get();
+        System.out.println("线程1执行之后，主线程取到的值：" + v);
+
+    }
+}
+

concurrency/src/main/java/com/javaedge/concurrency/example/threadLocal/RequestHolder.java

@@ -1,5 +1,10 @@
 package com.javaedge.concurrency.example.threadLocal;
 
+/**
+ *
+ * @author JavaEdge
+ * @date 2019/10/9
+ */
 public class RequestHolder {
 
     private final static ThreadLocal<Long> requestHolder = new ThreadLocal<>();

concurrency/src/main/java/com/javaedge/concurrency/example/threadLocal/ThreadLocalController.java

@@ -4,6 +4,11 @@
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.ResponseBody;
 
+/**
+ *
+ * @author JavaEdge
+ * @date 2019/10/9
+ */
 @Controller
 @RequestMapping("/threadLocal")
 public class ThreadLocalController {

concurrency/src/main/java/com/javaedge/concurrency/example/threadPool/ThreadPoolExample1.java renamed to concurrency/src/main/java/com/javaedge/concurrency/example/threadpool/ThreadPoolExample1.java

@@ -1,10 +1,15 @@
-package com.javaedge.concurrency.example.threadPool;
+package com.javaedge.concurrency.example.threadpool;
 
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
+/**
+ *
+ * @author JavaEdge
+ * @date 2019/10/9
+ */
 @Slf4j
 public class ThreadPoolExample1 {
 
@@ -14,12 +19,7 @@ public static void main(String[] args) {
 
         for (int i = 0; i < 10; i++) {
             final int index = i;
-            executorService.execute(new Runnable() {
-                @Override
-                public void run() {
-                    log.info("task:{}", index);
-                }
-            });
+            executorService.execute(() -> log.info("task:{}", index));
         }
         executorService.shutdown();
     }

concurrency/src/main/java/com/javaedge/concurrency/example/threadPool/ThreadPoolExample2.java renamed to concurrency/src/main/java/com/javaedge/concurrency/example/threadpool/ThreadPoolExample2.java

@@ -1,10 +1,15 @@
-package com.javaedge.concurrency.example.threadPool;
+package com.javaedge.concurrency.example.threadpool;
 
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
+/**
+ *
+ * @author JavaEdge
+ * @date 2019/10/9
+ */
 @Slf4j
 public class ThreadPoolExample2 {
 
@@ -14,12 +19,7 @@ public static void main(String[] args) {
 
         for (int i = 0; i < 10; i++) {
             final int index = i;
-            executorService.execute(new Runnable() {
-                @Override
-                public void run() {
-                    log.info("task:{}", index);
-                }
-            });
+            executorService.execute(() -> log.info("task:{}", index));
         }
         executorService.shutdown();
     }

concurrency/src/main/java/com/javaedge/concurrency/example/threadPool/ThreadPoolExample3.java renamed to concurrency/src/main/java/com/javaedge/concurrency/example/threadpool/ThreadPoolExample3.java

@@ -1,10 +1,15 @@
-package com.javaedge.concurrency.example.threadPool;
+package com.javaedge.concurrency.example.threadpool;
 
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
+/**
+ *
+ * @author JavaEdge
+ * @date 2019/10/9
+ */
 @Slf4j
 public class ThreadPoolExample3 {
 
@@ -14,12 +19,7 @@ public static void main(String[] args) {
 
         for (int i = 0; i < 10; i++) {
             final int index = i;
-            executorService.execute(new Runnable() {
-                @Override
-                public void run() {
-                    log.info("task:{}", index);
-                }
-            });
+            executorService.execute(() -> log.info("task:{}", index));
         }
         executorService.shutdown();
     }

concurrency/src/main/java/com/javaedge/concurrency/example/threadPool/ThreadPoolExample4.java renamed to concurrency/src/main/java/com/javaedge/concurrency/example/threadpool/ThreadPoolExample4.java

@@ -1,4 +1,4 @@
-package com.javaedge.concurrency.example.threadPool;
+package com.javaedge.concurrency.example.threadpool;
 
 import lombok.extern.slf4j.Slf4j;
 
@@ -9,6 +9,11 @@
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 
+/**
+ *
+ * @author JavaEdge
+ * @date 2019/10/9
+ */
 @Slf4j
 public class ThreadPoolExample4 {
 
@@ -23,12 +28,7 @@ public static void main(String[] args) {
 //            }
 //        }, 3, TimeUnit.SECONDS);
 
-        executorService.scheduleAtFixedRate(new Runnable() {
-            @Override
-            public void run() {
-                log.warn("schedule run");
-            }
-        }, 1, 3, TimeUnit.SECONDS);
+        executorService.scheduleAtFixedRate(() -> log.warn("schedule run"), 1, 3, TimeUnit.SECONDS);
 //        executorService.shutdown();
 
         Timer timer = new Timer();