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 beforeCloseListener; - // --------------------- fast-write-start --------------------- + // --------------------- clientMode: fast-write-start --------------------- protected ByteArray fastWriteArray; protected Queue> 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 bufferConsumer; + // 应用于clientMode模式 private final Queue fastQueue = new ConcurrentLinkedQueue<>(); private final Queue commandQueue = new ConcurrentLinkedQueue<>();