io.netty.channel

Class ThreadPerChannelEventLoop

java.lang.Object

java.util.concurrent.AbstractExecutorService

io.netty.util.concurrent.AbstractEventExecutor

io.netty.util.concurrent.AbstractScheduledEventExecutor

io.netty.util.concurrent.SingleThreadEventExecutor

io.netty.channel.SingleThreadEventLoop

io.netty.channel.ThreadPerChannelEventLoop

All Implemented Interfaces:

EventLoop, EventLoopGroup, EventExecutor, EventExecutorGroup, AutoCloseable, Executor, ExecutorService, ScheduledExecutorService

public class ThreadPerChannelEventLoop
extends SingleThreadEventLoop

SingleThreadEventLoop which is used to handle OIO Channel's. So in general there will be one ThreadPerChannelEventLoop per Channel.

Constructor Summary

Constructors

Constructor and Description
ThreadPerChannelEventLoop(ThreadPerChannelEventLoopGroup parent)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	deregister()
ChannelFuture	register(Channel channel, ChannelPromise promise) Register a Channel with an EventLoop from this EventLoopGroup.
protected void	run()

Methods inherited from class io.netty.channel.SingleThreadEventLoop

asInvoker, next, parent, register, unwrap, wakesUpForTask

Methods inherited from class io.netty.util.concurrent.SingleThreadEventExecutor

addShutdownHook, addTask, awaitTermination, cleanup, cleanupAndTerminate, confirmShutdown, delayNanos, execute, hasTasks, inEventLoop, isShutdown, isShuttingDown, isTerminated, newTaskQueue, peekTask, pendingTasks, pollTask, reject, removeShutdownHook, removeTask, runAllTasks, runAllTasks, scheduleExecution, shutdown, shutdownGracefully, takeTask, terminationFuture, updateLastExecutionTime, wakeup

Methods inherited from class io.netty.util.concurrent.AbstractScheduledEventExecutor

cancelScheduledTasks, hasScheduledTasks, nanoTime, nextScheduledTaskNano, pollScheduledTask, pollScheduledTask, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay

Methods inherited from class io.netty.util.concurrent.AbstractEventExecutor

children, close, inEventLoop, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, newTaskFor, newTaskFor, shutdownGracefully, shutdownNow, submit, submit, submit

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.util.concurrent.EventExecutor

children, inEventLoop, inEventLoop, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture

Methods inherited from interface io.netty.util.concurrent.EventExecutorGroup

isShuttingDown, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdown, shutdownGracefully, shutdownGracefully, shutdownNow, submit, submit, submit, terminationFuture

Methods inherited from interface java.util.concurrent.ExecutorService

awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated

Methods inherited from interface java.util.concurrent.Executor

execute

Methods inherited from interface java.lang.AutoCloseable

close

Constructor Detail

ThreadPerChannelEventLoop

public ThreadPerChannelEventLoop(ThreadPerChannelEventLoopGroup parent)

Method Detail

register

public ChannelFuture register(Channel channel,
                     ChannelPromise promise)

Description copied from interface: EventLoopGroup

Register a Channel with an EventLoop from this EventLoopGroup. The provided ChannelPromise will get notified once the registration is completed. The returned ChannelFuture is the same ChannelPromise that was passed to the method.

It's only safe to submit a new task to the EventLoop from within a ChannelHandler once the ChannelPromise succeeded. Otherwise the task may or may not be rejected.

Specified by:

register in interface EventLoopGroup

Overrides:

register in class SingleThreadEventLoop

run

protected void run()

Specified by:

run in class SingleThreadEventExecutor

deregister

protected void deregister()