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() {