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

优化iothread

Browse Source
This commit is contained in:
redkale
2023-04-07 14:57:43 +08:00
parent e6a2167261
commit 41d0cbcb46
3 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -182,12 +182,12 @@ public class AsyncIOThread extends WorkThread {
if (key.isConnectable()) {
key.interestOps(key.interestOps() & ~SelectionKey.OP_CONNECT);
conn.doConnect();
} else if (conn.readCompletionHandler != null && key.isReadable()) {
key.interestOps(key.interestOps() & ~SelectionKey.OP_READ);
conn.doRead(true);
} else if (conn.writeCompletionHandler != null && key.isWritable()) {
key.interestOps(key.interestOps() & ~SelectionKey.OP_WRITE);
conn.doWrite(true);
} else if (conn.readCompletionHandler != null && key.isReadable()) {
key.interestOps(key.interestOps() & ~SelectionKey.OP_READ);
conn.doRead(true);
}
} else {
if (conn.readCompletionHandler != null && key.isReadable()) {

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

@@ -397,9 +397,9 @@ abstract class AsyncNioConnection extends AsyncConnection {
if (writeCount == 0) {
if (hasRemain) {
writeCompleted = false;
writeTotal = totalCount;
//continue; //要全部输出完才返回
//writeCompleted = false;
//writeTotal = totalCount;
continue; //要全部输出完才返回
}
break;
} else if (writeCount < 0) {