lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

redkale.net.invoker.max.onstack榛樿鍊兼敼鎴?

Browse Source
This commit is contained in:
Redkale
2023-01-05 11:06:13 +08:00
parent 6f9a6e32bd
commit 288cab7c4f
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/org/redkale/net/AsyncNioConnection.java
View File

@@ -27,7 +27,7 @@ import org.redkale.util.ByteBufferWriter;
*/ */
abstract class AsyncNioConnection extends AsyncConnection { 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; final AsyncIOThread connectThread;
@@ -164,7 +164,7 @@ abstract class AsyncNioConnection extends AsyncConnection {
if (client) { if (client) {
doRead(this.ioReadThread.inCurrThread()); doRead(this.ioReadThread.inCurrThread());
} else { } else {
doRead(currReadInvoker < MAX_INVOKER_ONSTACK || this.ioReadThread.inCurrThread()); //同一线程中Selector.wakeup无效 doRead(this.ioReadThread.inCurrThread() || currReadInvoker < MAX_INVOKER_ONSTACK); //同一线程中Selector.wakeup无效
} }
} }