From bb4482c08ca1260d422486fe41ff35eed7bdf281 Mon Sep 17 00:00:00 2001
From: Redkale <redkale@qq.com>
Date: Mon, 9 Jan 2023 12:18:32 +0800
Subject: [PATCH] =?UTF-8?q?=E7=A7=BB=E9=99=A4MAX=5FINVOKER=5FONSTACK?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/org/redkale/net/AsyncNioConnection.java  | 15 ++++++++-------
 1 file changed, 8 insertions(+), 7 deletions(-)

diff --git a/src/main/java/org/redkale/net/AsyncNioConnection.java b/src/main/java/org/redkale/net/AsyncNioConnection.java
index a30c299c0..95f75726b 100644
--- a/src/main/java/org/redkale/net/AsyncNioConnection.java
+++ b/src/main/java/org/redkale/net/AsyncNioConnection.java
@@ -14,7 +14,7 @@ import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.LongAdder;
 import java.util.function.Consumer;
 import javax.net.ssl.SSLContext;
-import org.redkale.util.*;
+import org.redkale.util.ByteBufferWriter;
 
 /**
  *
@@ -27,7 +27,7 @@ import org.redkale.util.*;
  */
 abstract class AsyncNioConnection extends AsyncConnection {
 
-    protected static final int MAX_INVOKER_ONSTACK = Integer.getInteger("redkale.net.invoker.max.onstack", Utility.cpus());
+    protected static final int MAX_INVOKER_ONSTACK = Integer.getInteger("redkale.net.invoker.max.onstack", 16);
 
     final AsyncIOThread connectThread;
 
@@ -161,11 +161,12 @@ abstract class AsyncNioConnection extends AsyncConnection {
         } else {
             this.readCompletionHandler = handler;
         }
-        if (client) {
-            doRead(this.ioReadThread.inCurrThread());
-        } else {
-            doRead(this.ioReadThread.inCurrThread() || currReadInvoker < MAX_INVOKER_ONSTACK); //同一线程中Selector.wakeup无效
-        }
+        doRead(this.ioReadThread.inCurrThread());
+//        if (client) {
+//            doRead(this.ioReadThread.inCurrThread());
+//        } else {
+//            doRead(this.ioReadThread.inCurrThread() || currReadInvoker < MAX_INVOKER_ONSTACK); //同一线程中Selector.wakeup无效
+//        }
     }
 
     @Override