Package io.netty.channel
Class AbstractChannelHandlerContext.WriteTask
java.lang.Object
io.netty.channel.AbstractChannelHandlerContext.WriteTask
- All Implemented Interfaces:
Runnable
- Enclosing class:
AbstractChannelHandlerContext
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate AbstractChannelHandlerContext
private static final boolean
private final ObjectPool.Handle
<AbstractChannelHandlerContext.WriteTask> private Object
private ChannelPromise
private static final ObjectPool
<AbstractChannelHandlerContext.WriteTask> private int
private static final int
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprivate
WriteTask
(ObjectPool.Handle<? extends AbstractChannelHandlerContext.WriteTask> handle) -
Method Summary
Modifier and TypeMethodDescription(package private) void
cancel()
private void
protected static void
init
(AbstractChannelHandlerContext.WriteTask task, AbstractChannelHandlerContext ctx, Object msg, ChannelPromise promise, boolean flush) (package private) static AbstractChannelHandlerContext.WriteTask
newInstance
(AbstractChannelHandlerContext ctx, Object msg, ChannelPromise promise, boolean flush) private void
recycle()
void
run()
-
Field Details
-
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
-
ctx
-
msg
-
promise
-
size
private int size
-
-
Constructor Details
-
WriteTask
-
-
Method Details
-
newInstance
static AbstractChannelHandlerContext.WriteTask newInstance(AbstractChannelHandlerContext ctx, Object msg, ChannelPromise promise, boolean flush) -
init
protected static void init(AbstractChannelHandlerContext.WriteTask task, AbstractChannelHandlerContext ctx, Object msg, ChannelPromise promise, boolean flush) -
run
public void run() -
cancel
void cancel() -
decrementPendingOutboundBytes
private void decrementPendingOutboundBytes() -
recycle
private void recycle()
-