From c43d151d4dddd1bb38fb2fd513ea8336b1e4f80c Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Sun, 27 Oct 2024 17:28:27 +0800
Subject: [PATCH] AsyncNioConnection

---
 src/main/java/org/redkale/net/AsyncNioConnection.java | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/src/main/java/org/redkale/net/AsyncNioConnection.java b/src/main/java/org/redkale/net/AsyncNioConnection.java
index dfae49ce5..9db399ba7 100644
--- a/src/main/java/org/redkale/net/AsyncNioConnection.java
+++ b/src/main/java/org/redkale/net/AsyncNioConnection.java
@@ -169,13 +169,10 @@ abstract class AsyncNioConnection extends AsyncConnection {
                 pipelineLock.unlock();
             }
         }
-        boolean empty = this.pipelineWriteQueue.isEmpty();
         for (PipelinePacket packet : packets) {
             this.pipelineWriteQueue.offer(packet);
         }
-        if (empty) {
-            this.ioWriteThread.execute(this::pipelineDoWrite);
-        }
+        this.ioWriteThread.execute(this::pipelineDoWrite);
     }
 
     private void pipelineDoWrite() {