添加 solon-server newVirtualThreadFactory 名字前缀支持

Author: noear

UPDATE_LOG.md

@@ -2,6 +2,7 @@
 ### v3.8.1
 
 * 新增 `solon-net-httputils-java11` 插件 //还有问题
+* 添加 `solon-server` newVirtualThreadFactory 名字前缀支持
 * 调整 项目的默认 java 版本改为 11；需要 17 的模块则指定 17 
 
 ### v3.8.0

solon-java17-projects/solon-net/solon-net-httputils-java11/src/main/java/org/noear/solon/net/http/impl/jdk/JdkHttpDispatcherLoader.java

@@ -37,12 +37,12 @@ public ExecutorService getDispatcher() {
             try {
                 if (dispatcher == null) {
                     if (Solon.appIf(app -> app.cfg().isEnabledVirtualThreads())) {
-                        dispatcher = ThreadsUtil.newVirtualThreadPerTaskExecutor();
+                        dispatcher = ThreadsUtil.newVirtualThreadPerTaskExecutor("http-dispatcher-");
                     } else {
                         dispatcher = new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                 60, TimeUnit.SECONDS,
                                 new SynchronousQueue<>()
-                                , new NamedThreadFactory("http-dispatcher").daemon(false));
+                                , new NamedThreadFactory("http-dispatcher-").daemon(false));
                     }
                 }
             } finally {

solon-java17-projects/solon-net/solon-net-httputils-java11/src/main/java/org/noear/solon/net/http/impl/okhttp/OkHttpDispatcherLoader.java

@@ -35,7 +35,7 @@ public Dispatcher getDispatcher() {
             try {
                 if (dispatcher == null) {
                     if (Solon.appIf(app -> app.cfg().isEnabledVirtualThreads())) {
-                        dispatcher = new Dispatcher(ThreadsUtil.newVirtualThreadPerTaskExecutor());
+                        dispatcher = new Dispatcher(ThreadsUtil.newVirtualThreadPerTaskExecutor("okhttp-"));
                     } else {
                         dispatcher = new Dispatcher();
                         dispatcher.setMaxRequests(Integer.MAX_VALUE);

solon-java17-projects/solon-server/solon-server-jetty-jakarta/src/main/java/org/noear/solon/server/jetty/JettyServer.java

@@ -61,7 +61,7 @@ protected void setup(String host, int port) throws IOException {
 
         //支持虚拟线程池
         if (Solon.appIf(app -> app.cfg().isEnabledVirtualThreads())) {
-            threadPool.setVirtualThreadsExecutor(ThreadsUtil.newVirtualThreadPerTaskExecutor());
+            threadPool.setVirtualThreadsExecutor(ThreadsUtil.newVirtualThreadPerTaskExecutor("jetty-"));
         }
 
         real = new Server(threadPool);

solon-java17-projects/solon-server/solon-server-tomcat-jakarta/src/main/java/org/noear/solon/server/tomcat/TomcatServer.java

@@ -111,7 +111,7 @@ protected void addConnector(int port, boolean isMain) throws IOException {
 
         if (Solon.appIf(app -> app.cfg().isEnabledVirtualThreads())) {
             //支持虚拟线程池
-            protocol.setExecutor(ThreadsUtil.newVirtualThreadPerTaskExecutor());
+            protocol.setExecutor(ThreadsUtil.newVirtualThreadPerTaskExecutor("tomcat-"));
         }
 
 

solon-java17-projects/solon-server/solon-server-undertow-jakarta/src/main/java/org/noear/solon/server/undertow/UndertowServer.java

@@ -133,8 +133,8 @@ protected HttpHandler buildHandler() throws Exception {
 
         if (Solon.appIf(app -> app.cfg().isEnabledVirtualThreads())) {
             //支持虚拟线程池
-            builder.setExecutor(ThreadsUtil.newVirtualThreadPerTaskExecutor());
-            builder.setAsyncExecutor(ThreadsUtil.newVirtualThreadPerTaskExecutor());
+            builder.setExecutor(ThreadsUtil.newVirtualThreadPerTaskExecutor("undertow-"));
+            builder.setAsyncExecutor(ThreadsUtil.newVirtualThreadPerTaskExecutor("undertow-async-"));
         }
 
         //添加servlet