public class ThreadPerChannelEventLoop extends SingleThreadEventLoop
SingleThreadEventLoop
which is used to handle OIO Channel
's. So in general there will be
one ThreadPerChannelEventLoop
per Channel
.SingleThreadEventLoop.NonWakeupRunnable
Modifier and Type | Field and Description |
---|---|
private Channel |
ch |
private ThreadPerChannelEventLoopGroup |
parent |
DEFAULT_MAX_PENDING_TASKS
Constructor and Description |
---|
ThreadPerChannelEventLoop(ThreadPerChannelEventLoopGroup parent) |
Modifier and Type | Method and Description |
---|---|
protected void |
deregister() |
ChannelFuture |
register(Channel channel,
ChannelPromise promise)
|
protected void |
run() |
next, parent, register, wakesUpForTask
addShutdownHook, addTask, awaitTermination, cleanup, confirmShutdown, delayNanos, execute, hasTasks, inEventLoop, interruptThread, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isShuttingDown, isTerminated, newTaskQueue, newTaskQueue, peekTask, pendingTasks, pollTask, reject, removeShutdownHook, removeTask, runAllTasks, runAllTasks, shutdown, shutdownGracefully, takeTask, terminationFuture, threadProperties, updateLastExecutionTime, wakeup
cancelScheduledTasks, hasScheduledTasks, nanoTime, nextScheduledTaskNano, pollScheduledTask, pollScheduledTask, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay
inEventLoop, iterator, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, newTaskFor, newTaskFor, shutdownGracefully, shutdownNow, submit, submit, submit
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
inEventLoop, inEventLoop, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture
isShuttingDown, iterator, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdown, shutdownGracefully, shutdownGracefully, shutdownNow, submit, submit, submit, terminationFuture
private final ThreadPerChannelEventLoopGroup parent
private Channel ch
public ThreadPerChannelEventLoop(ThreadPerChannelEventLoopGroup parent)
public ChannelFuture register(Channel channel, ChannelPromise promise)
EventLoopGroup
Channel
with this EventLoop
. The passed ChannelFuture
will get notified once the registration was complete and also will get returned.register
in interface EventLoopGroup
register
in class SingleThreadEventLoop
protected void run()
run
in class SingleThreadEventExecutor
protected void deregister()