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

优化doWrite

Browse Source
This commit is contained in:
redkale
2023-01-28 11:58:27 +08:00
parent 2a7f0901af
commit 83b4887dd6
1 changed files with 554 additions and 554 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -192,7 +192,7 @@ abstract class AsyncNioConnection extends AsyncConnection {
newHandler.handler(handler, null); // new AsyncNioCompletionHandler(handler, null); newHandler.handler(handler, null); // new AsyncNioCompletionHandler(handler, null);
this.writeCompletionHandler = newHandler; this.writeCompletionHandler = newHandler;
} }
doWrite(this.ioWriteThread.inCurrThread()); //如果不是true，则bodyCallback的执行可能会切换线程 doWrite(true); //如果不是true，则bodyCallback的执行可能会切换线程
} }
@Override @Override
@@ -218,7 +218,7 @@ abstract class AsyncNioConnection extends AsyncConnection {
} else { } else {
this.writeCompletionHandler = (CompletionHandler) handler; this.writeCompletionHandler = (CompletionHandler) handler;
} }
doWrite(this.ioWriteThread.inCurrThread()); doWrite(true);
} }
@Override @Override
@@ -246,7 +246,7 @@ abstract class AsyncNioConnection extends AsyncConnection {
} else { } else {
this.writeCompletionHandler = (CompletionHandler) handler; this.writeCompletionHandler = (CompletionHandler) handler;
} }
doWrite(this.ioWriteThread.inCurrThread()); doWrite(true);
} }
public void doRead(boolean direct) { public void doRead(boolean direct) {