diff --git a/src/main/java/org/redkale/net/AsyncNioConnection.java b/src/main/java/org/redkale/net/AsyncNioConnection.java
index 37c1e8b8a..8eee4ae69 100644
--- a/src/main/java/org/redkale/net/AsyncNioConnection.java
+++ b/src/main/java/org/redkale/net/AsyncNioConnection.java
@@ -160,13 +160,13 @@ abstract class AsyncNioConnection extends AsyncConnection {
     @Override
     public final void pipelineWrite(PipelinePacket... packets) {
         if (pipelineWriteQueue == null) {
-            writeLock.lock();
+            lockWrite();
             try {
                 if (pipelineWriteQueue == null) {
                     pipelineWriteQueue = new ConcurrentLinkedDeque<>();
                 }
             } finally {
-                writeLock.unlock();
+                unlockWrite();
             }
         }
         for (PipelinePacket packet : packets) {