注释
This commit is contained in:
@@ -84,13 +84,13 @@ public abstract class AsyncConnection implements Channel, AutoCloseable {
|
|||||||
|
|
||||||
private Consumer<AsyncConnection> beforeCloseListener;
|
private Consumer<AsyncConnection> beforeCloseListener;
|
||||||
|
|
||||||
// --------------------- fast-write-start ---------------------
|
// --------------------- clientMode: fast-write-start ---------------------
|
||||||
protected ByteArray fastWriteArray;
|
protected ByteArray fastWriteArray;
|
||||||
|
|
||||||
protected Queue<Consumer<ByteArray>> fastWriteQueue;
|
protected Queue<Consumer<ByteArray>> fastWriteQueue;
|
||||||
|
|
||||||
protected CompletionHandler fastWriteHandler;
|
protected CompletionHandler fastWriteHandler;
|
||||||
// --------------------- fast-write-end ---------------------
|
// --------------------- clientMode: fast-write-end ---------------------
|
||||||
|
|
||||||
// 用于服务端的Socket, 等同于一直存在的readCompletionHandler
|
// 用于服务端的Socket, 等同于一直存在的readCompletionHandler
|
||||||
ProtocolCodec protocolCodec;
|
ProtocolCodec protocolCodec;
|
||||||
|
|||||||
@@ -33,6 +33,7 @@ public class AsyncIOThread extends WorkThread {
|
|||||||
|
|
||||||
private final Consumer<ByteBuffer> bufferConsumer;
|
private final Consumer<ByteBuffer> bufferConsumer;
|
||||||
|
|
||||||
|
// 应用于clientMode模式
|
||||||
private final Queue<AsyncConnection> fastQueue = new ConcurrentLinkedQueue<>();
|
private final Queue<AsyncConnection> fastQueue = new ConcurrentLinkedQueue<>();
|
||||||
|
|
||||||
private final Queue<Runnable> commandQueue = new ConcurrentLinkedQueue<>();
|
private final Queue<Runnable> commandQueue = new ConcurrentLinkedQueue<>();
|
||||||
|
|||||||
Reference in New Issue
Block a user