From dc6d53e6beca4eae4150dd6936e36a31aabd37be Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Mon, 3 Apr 2023 14:48:01 +0800
Subject: [PATCH] =?UTF-8?q?=E6=97=A5=E5=BF=97=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/org/redkale/net/Server.java | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/src/main/java/org/redkale/net/Server.java b/src/main/java/org/redkale/net/Server.java
index 67999a8d5..e4311ef12 100644
--- a/src/main/java/org/redkale/net/Server.java
+++ b/src/main/java/org/redkale/net/Server.java
@@ -9,6 +9,7 @@ import java.io.*;
 import java.net.*;
 import java.nio.charset.Charset;
 import java.util.*;
+import java.util.concurrent.*;
 import java.util.concurrent.atomic.LongAdder;
 import java.util.logging.*;
 import javax.net.ssl.SSLContext;
@@ -313,8 +314,18 @@ public abstract class Server<K extends Serializable, C extends Context, R extend
         }
         serverChannel.accept(application, this);
         postStart();
+        ExecutorService workExecutor = context.workExecutor;
+        int workThreads = 0;
+        if (workExecutor instanceof ThreadPoolExecutor) {
+            workThreads = ((ThreadPoolExecutor) workExecutor).getCorePoolSize();
+        } else if (workExecutor instanceof ThreadHashExecutor) {
+            workThreads = ((ThreadHashExecutor) workExecutor).getCorePoolSize();
+        } else if (workExecutor != null) { //virtual thread pool
+            workThreads = -1;
+        }
         logger.info(this.getClass().getSimpleName() + ("TCP".equalsIgnoreCase(netprotocol) ? "" : ("." + netprotocol)) + " listen: " + (address.getHostString() + ":" + address.getPort())
-            + ", cpu: " + Utility.cpus() + ", responsePoolSize: " + responsePoolSize + ", bufferPoolSize: " + bufferPoolSize
+            + ", cpu: " + Utility.cpus() + ", workThreads: " + (workThreads >= 0 ? workThreads : "[virtual]")
+            + ", responsePoolSize: " + responsePoolSize + ", bufferPoolSize: " + bufferPoolSize
             + ", bufferCapacity: " + formatLenth(bufferCapacity) + ", maxbody: " + formatLenth(context.maxBody) + startExtLog()
             + ", started in " + (System.currentTimeMillis() - context.getServerStartTime()) + " ms\r\n");
     }