Class AbstractChannelHandlerContext.WriteTask

java.lang.Object

io.netty.channel.AbstractChannelHandlerContext.WriteTask

All Implemented Interfaces:

Runnable

Enclosing class:

AbstractChannelHandlerContext

static final class AbstractChannelHandlerContext.WriteTask
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field	Description
private AbstractChannelHandlerContext	ctx
private static final boolean	ESTIMATE_TASK_SIZE_ON_SUBMIT
private final ObjectPool.Handle<AbstractChannelHandlerContext.WriteTask>	handle
private Object	msg
private ChannelPromise	promise
private static final ObjectPool<AbstractChannelHandlerContext.WriteTask>	RECYCLER
private int	size
private static final int	WRITE_TASK_OVERHEAD

Constructor Summary

Constructors

Modifier	Constructor	Description
private	WriteTask(ObjectPool.Handle<? extends AbstractChannelHandlerContext.WriteTask> handle)

Method Summary

Modifier and Type	Method	Description
(package private) void	cancel()
private void	decrementPendingOutboundBytes()
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()

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

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 Object msg

promise

private ChannelPromise promise

size

private int size

Constructor Details

WriteTask

private WriteTask(ObjectPool.Handle<? extends AbstractChannelHandlerContext.WriteTask> handle)

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()

Specified by:

run in interface Runnable

cancel

void cancel()

decrementPendingOutboundBytes

private void decrementPendingOutboundBytes()

recycle

private void recycle()