From f33ac5f88a398f5d213a76de8d02c48d12a99482 Mon Sep 17 00:00:00 2001 From: redkale Date: Mon, 28 Oct 2024 10:41:55 +0800 Subject: [PATCH] pipelineWrite --- src/main/java/org/redkale/net/AsyncNioConnection.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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) {