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 AbstractChannelHandlerContext
ctx
private static boolean
ESTIMATE_TASK_SIZE_ON_SUBMIT
private ObjectPool.Handle<AbstractChannelHandlerContext.WriteTask>
handle
private java.lang.Object
msg
private ChannelPromise
promise
private static ObjectPool<AbstractChannelHandlerContext.WriteTask>
RECYCLER
private int
size
private static int
WRITE_TASK_OVERHEAD
-
Constructor Summary
Constructors Modifier Constructor Description private
WriteTask(ObjectPool.Handle<? extends AbstractChannelHandlerContext.WriteTask> handle)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
cancel()
private void
decrementPendingOutboundBytes()
protected static void
init(AbstractChannelHandlerContext.WriteTask task, AbstractChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise, boolean flush)
(package private) static AbstractChannelHandlerContext.WriteTask
newInstance(AbstractChannelHandlerContext ctx, java.lang.Object msg, ChannelPromise promise, boolean flush)
private void
recycle()
void
run()
-
-
-
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:
run
in interfacejava.lang.Runnable
-
cancel
void cancel()
-
decrementPendingOutboundBytes
private void decrementPendingOutboundBytes()
-
recycle
private void recycle()
-
-