From a90c94a40c55b2271bdfc2df5f6ad315f305b74e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E4=B8=89=E4=B8=99?= <sanbing-os@foxmail.com>
Date: Wed, 16 Oct 2024 10:20:35 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B6=88=E8=B4=B9=E5=A4=84=E7=90=86=E7=BA=BF?=
 =?UTF-8?q?=E7=A8=8B=E6=B1=A0=E6=9B=B4=E6=8D=A2=E4=B8=BA=E8=99=9A=E6=8B=9F?=
 =?UTF-8?q?=E7=BA=BF=E7=A8=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../util/async/JCPPVirtualThreadFactory.java  |  4 +--
 .../util/async/JCPPExecutorsTest.java         | 30 +++++++++++++++++++
 2 files changed, 31 insertions(+), 3 deletions(-)
 create mode 100644 jcpp-infrastructure-util/src/test/java/sanbing/jcpp/infrastructure/util/async/JCPPExecutorsTest.java

diff --git a/jcpp-infrastructure-util/src/main/java/sanbing/jcpp/infrastructure/util/async/JCPPVirtualThreadFactory.java b/jcpp-infrastructure-util/src/main/java/sanbing/jcpp/infrastructure/util/async/JCPPVirtualThreadFactory.java
index 2c88144..4edcc68 100644
--- a/jcpp-infrastructure-util/src/main/java/sanbing/jcpp/infrastructure/util/async/JCPPVirtualThreadFactory.java
+++ b/jcpp-infrastructure-util/src/main/java/sanbing/jcpp/infrastructure/util/async/JCPPVirtualThreadFactory.java
@@ -4,8 +4,6 @@
  */
 package sanbing.jcpp.infrastructure.util.async;
 
-import sanbing.jcpp.infrastructure.util.trace.TracerRunnable;
-
 import java.util.concurrent.ThreadFactory;
 import java.util.concurrent.atomic.AtomicLong;
 
@@ -19,6 +17,6 @@ public class JCPPVirtualThreadFactory implements ThreadFactory {
 
     @Override
     public Thread newThread(Runnable r) {
-        return Thread.ofVirtual().name(namePrefix + "-" + threadNumber.getAndIncrement()).unstarted(new TracerRunnable(r));
+        return Thread.ofVirtual().name(namePrefix + "-" + threadNumber.getAndIncrement()).unstarted(r);
     }
 }
\ No newline at end of file
diff --git a/jcpp-infrastructure-util/src/test/java/sanbing/jcpp/infrastructure/util/async/JCPPExecutorsTest.java b/jcpp-infrastructure-util/src/test/java/sanbing/jcpp/infrastructure/util/async/JCPPExecutorsTest.java
new file mode 100644
index 0000000..418a630
--- /dev/null
+++ b/jcpp-infrastructure-util/src/test/java/sanbing/jcpp/infrastructure/util/async/JCPPExecutorsTest.java
@@ -0,0 +1,30 @@
+/**
+ * 抖音关注：程序员三丙
+ * 知识星球：https://t.zsxq.com/j9b21
+ */
+package sanbing.jcpp.infrastructure.util.async;
+
+import org.junit.jupiter.api.Test;
+import org.slf4j.MDC;
+import sanbing.jcpp.infrastructure.util.mdc.MDCUtils;
+import sanbing.jcpp.infrastructure.util.trace.TracerContextUtil;
+import sanbing.jcpp.infrastructure.util.trace.TracerRunnable;
+
+import java.util.concurrent.ExecutorService;
+
+class JCPPExecutorsTest {
+
+    @Test
+    void newVirtualThreadPool() {
+        ExecutorService executorService = JCPPExecutors.newVirtualThreadPool("test-consumer-virtual");
+
+        TracerContextUtil.newTracer();
+        MDCUtils.recordTracer();
+
+        System.out.println(MDC.get("TRACE_ID"));
+
+        executorService.submit(new TracerRunnable(() -> {
+            System.out.println(MDC.get("TRACE_ID"));
+        }));
+    }
+}
\ No newline at end of file