public class ReqQueue
extends java.lang.Object
| 限定符和类型 | 字段和说明 |
|---|---|
static io.netty.util.AttributeKey<ReqQueue> |
REQ_QUEUE |
static int |
RES_COUNT_THRESHOLD |
static int |
TIMEOUT_IN_MILLIS |
| 构造器和说明 |
|---|
ReqQueue() |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
offer(Request request) |
Request |
poll() |
java.util.List<Request> |
removeTimeout()
删除并返回超时未处理的request列表
|
void |
writeAndFlush(ResponseWrapper... responses) |
public static final int RES_COUNT_THRESHOLD
public static final int TIMEOUT_IN_MILLIS
public static final io.netty.util.AttributeKey<ReqQueue> REQ_QUEUE
public void writeAndFlush(ResponseWrapper... responses)
public void offer(Request request)
public Request poll()
public java.util.List<Request> removeTimeout()