From 288cab7c4f7065aa574a86d3351aa5e056f091d0 Mon Sep 17 00:00:00 2001 From: Redkale Date: Thu, 5 Jan 2023 11:06:13 +0800 Subject: [PATCH] =?UTF-8?q?redkale.net.invoker.max.onstack=E6=A6=9B?= =?UTF-8?q?=E6=A8=BF=EE=85=BB=E9=8D=8A=E5=85=BC=E6=95=BC=E9=8E=B4=3F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/org/redkale/net/AsyncNioConnection.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/org/redkale/net/AsyncNioConnection.java b/src/main/java/org/redkale/net/AsyncNioConnection.java index 9832e49b8..309951de4 100644 --- a/src/main/java/org/redkale/net/AsyncNioConnection.java +++ b/src/main/java/org/redkale/net/AsyncNioConnection.java @@ -27,7 +27,7 @@ import org.redkale.util.ByteBufferWriter; */ abstract class AsyncNioConnection extends AsyncConnection { - protected static final int MAX_INVOKER_ONSTACK = Integer.getInteger("redkale.net.invoker.max.onstack", 16); + protected static final int MAX_INVOKER_ONSTACK = Integer.getInteger("redkale.net.invoker.max.onstack", 8); final AsyncIOThread connectThread; @@ -164,7 +164,7 @@ abstract class AsyncNioConnection extends AsyncConnection { if (client) { doRead(this.ioReadThread.inCurrThread()); } else { - doRead(currReadInvoker < MAX_INVOKER_ONSTACK || this.ioReadThread.inCurrThread()); //同一线程中Selector.wakeup无效 + doRead(this.ioReadThread.inCurrThread() || currReadInvoker < MAX_INVOKER_ONSTACK); //同一线程中Selector.wakeup无效 } }