abstract static class AbstractChannelHandlerContext.AbstractWriteTask
extends java.lang.Object
implements java.lang.Runnable
| Modifier and Type | Field and Description |
|---|---|
private AbstractChannelHandlerContext |
ctx |
private static boolean |
ESTIMATE_TASK_SIZE_ON_SUBMIT |
private Recycler.Handle<AbstractChannelHandlerContext.AbstractWriteTask> |
handle |
private java.lang.Object |
msg |
private ChannelPromise |
promise |
private int |
size |
private static int |
WRITE_TASK_OVERHEAD |
| Modifier | Constructor and Description |
|---|---|
private |
AbstractWriteTask(Recycler.Handle<? extends AbstractChannelHandlerContext.AbstractWriteTask> handle) |
| Modifier and Type | Method and Description |
|---|---|
protected static void |
init(AbstractChannelHandlerContext.AbstractWriteTask task,
AbstractChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
void |
run() |
protected void |
write(AbstractChannelHandlerContext ctx,
java.lang.Object msg,
ChannelPromise promise) |
private static final boolean ESTIMATE_TASK_SIZE_ON_SUBMIT
private static final int WRITE_TASK_OVERHEAD
private final Recycler.Handle<AbstractChannelHandlerContext.AbstractWriteTask> handle
private AbstractChannelHandlerContext ctx
private java.lang.Object msg
private ChannelPromise promise
private int size
private AbstractWriteTask(Recycler.Handle<? extends AbstractChannelHandlerContext.AbstractWriteTask> handle)
protected static void init(AbstractChannelHandlerContext.AbstractWriteTask task, AbstractChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)
public final void run()
run in interface java.lang.Runnableprotected void write(AbstractChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise)