Package io.netty.channel
Class AbstractChannelHandlerContext.WriteTask
- java.lang.Object
-
- io.netty.channel.AbstractChannelHandlerContext.WriteTask
-
- All Implemented Interfaces:
java.lang.Runnable
- Enclosing class:
- AbstractChannelHandlerContext
static final class AbstractChannelHandlerContext.WriteTask extends java.lang.Object implements java.lang.Runnable
-
-
Field Summary
Fields Modifier and Type Field Description private AbstractChannelHandlerContextctxprivate static booleanESTIMATE_TASK_SIZE_ON_SUBMITprivate ObjectPool.Handle<AbstractChannelHandlerContext.WriteTask>handleprivate java.lang.Objectmsgprivate ChannelPromisepromiseprivate static ObjectPool<AbstractChannelHandlerContext.WriteTask>RECYCLERprivate intsizeprivate static intWRITE_TASK_OVERHEAD
-
Constructor Summary
Constructors Modifier Constructor Description privateWriteTask(ObjectPool.Handle<? extends AbstractChannelHandlerContext.WriteTask> handle)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) voidcancel()private voiddecrementPendingOutboundBytes()protected static voidinit(AbstractChannelHandlerContext.WriteTask task, AbstractChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise, boolean flush)(package private) static AbstractChannelHandlerContext.WriteTasknewInstance(AbstractChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise, boolean flush)private voidrecycle()voidrun()
-
-
-
Field Detail
-
RECYCLER
private static final ObjectPool<AbstractChannelHandlerContext.WriteTask> RECYCLER
-
ESTIMATE_TASK_SIZE_ON_SUBMIT
private static final boolean ESTIMATE_TASK_SIZE_ON_SUBMIT
-
WRITE_TASK_OVERHEAD
private static final int WRITE_TASK_OVERHEAD
-
handle
private final ObjectPool.Handle<AbstractChannelHandlerContext.WriteTask> handle
-
ctx
private AbstractChannelHandlerContext ctx
-
msg
private java.lang.Object msg
-
promise
private ChannelPromise promise
-
size
private int size
-
-
Constructor Detail
-
WriteTask
private WriteTask(ObjectPool.Handle<? extends AbstractChannelHandlerContext.WriteTask> handle)
-
-
Method Detail
-
newInstance
static AbstractChannelHandlerContext.WriteTask newInstance(AbstractChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise, boolean flush)
-
init
protected static void init(AbstractChannelHandlerContext.WriteTask task, AbstractChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise, boolean flush)
-
run
public void run()
- Specified by:
runin interfacejava.lang.Runnable
-
cancel
void cancel()
-
decrementPendingOutboundBytes
private void decrementPendingOutboundBytes()
-
recycle
private void recycle()
-
-