From 77a8b8fa7f85428aeea2b0052a6a79f9255f6441 Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Mon, 7 Oct 2024 21:51:53 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B3=A8=E9=87=8A?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/org/redkale/net/AsyncConnection.java | 4 ++--
 src/main/java/org/redkale/net/AsyncIOThread.java   | 1 +
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/main/java/org/redkale/net/AsyncConnection.java b/src/main/java/org/redkale/net/AsyncConnection.java
index d83369e5a..e79d37586 100644
--- a/src/main/java/org/redkale/net/AsyncConnection.java
+++ b/src/main/java/org/redkale/net/AsyncConnection.java
@@ -84,13 +84,13 @@ public abstract class AsyncConnection implements Channel, AutoCloseable {
 
     private Consumer<AsyncConnection> beforeCloseListener;
 
-    // --------------------- fast-write-start ---------------------
+    // --------------------- clientMode: fast-write-start ---------------------
     protected ByteArray fastWriteArray;
 
     protected Queue<Consumer<ByteArray>> fastWriteQueue;
 
     protected CompletionHandler fastWriteHandler;
-    // --------------------- fast-write-end ---------------------
+    // --------------------- clientMode: fast-write-end ---------------------
 
     // 用于服务端的Socket, 等同于一直存在的readCompletionHandler
     ProtocolCodec protocolCodec;
diff --git a/src/main/java/org/redkale/net/AsyncIOThread.java b/src/main/java/org/redkale/net/AsyncIOThread.java
index adc6cfff3..f72c59e38 100644
--- a/src/main/java/org/redkale/net/AsyncIOThread.java
+++ b/src/main/java/org/redkale/net/AsyncIOThread.java
@@ -33,6 +33,7 @@ public class AsyncIOThread extends WorkThread {
 
     private final Consumer<ByteBuffer> bufferConsumer;
 
+    // 应用于clientMode模式
     private final Queue<AsyncConnection> fastQueue = new ConcurrentLinkedQueue<>();
 
     private final Queue<Runnable> commandQueue = new ConcurrentLinkedQueue<>();