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

AsyncNioConnection

Browse Source
This commit is contained in:
redkale
2024-10-27 17:28:27 +08:00
parent f3f84bd5b3
commit c43d151d4d
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -169,13 +169,10 @@ abstract class AsyncNioConnection extends AsyncConnection {
pipelineLock.unlock(); pipelineLock.unlock();
} }
} }
boolean empty = this.pipelineWriteQueue.isEmpty();
for (PipelinePacket packet : packets) { for (PipelinePacket packet : packets) {
this.pipelineWriteQueue.offer(packet); this.pipelineWriteQueue.offer(packet);
} }
if (empty) { this.ioWriteThread.execute(this::pipelineDoWrite);
this.ioWriteThread.execute(this::pipelineDoWrite);
}
} }
private void pipelineDoWrite() { private void pipelineDoWrite() {