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, OrderedEventExecutor, ThreadAwareExecutor, java.lang.Iterable<EventExecutor>, java.util.concurrent.Executor, java.util.concurrent.ExecutorService, java.util.concurrent.ScheduledExecutorService

@Deprecated
public class ThreadPerChannelEventLoop
extends SingleThreadEventLoop

Deprecated.

this will be remove in the next-major release.

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

Nested Class Summary

Nested classes/interfaces inherited from class SingleThreadEventLoop

SingleThreadEventLoop.ChannelsReadOnlyIterator<T>

Nested classes/interfaces inherited from class SingleThreadEventExecutor

SingleThreadEventExecutor.NonWakeupRunnable

Nested classes/interfaces inherited from class AbstractEventExecutor

AbstractEventExecutor.LazyRunnable

Field Summary

Fields

Modifier and Type	Field	Description
private Channel	ch	Deprecated.
private final ThreadPerChannelEventLoopGroup	parent	Deprecated.

Fields inherited from class SingleThreadEventLoop

DEFAULT_MAX_PENDING_TASKS

Constructor Summary

Constructors

Constructor	Description
ThreadPerChannelEventLoop(ThreadPerChannelEventLoopGroup parent)	Deprecated.

Method Summary

Modifier and Type	Method	Description
protected void	deregister()	Deprecated.
ChannelFuture	register(ChannelPromise promise)	Deprecated. Register a Channel with this EventLoop using a ChannelFuture.
ChannelFuture	register(Channel channel, ChannelPromise promise)	Deprecated.
int	registeredChannels()	Deprecated. Returns the number of Channels registered with this EventLoop or -1 if operation is not supported.
protected void	run()	Deprecated. Runs the task-processing loop until SingleThreadEventExecutor.confirmShutdown() returns true.

Methods inherited from class SingleThreadEventLoop

afterRunningAllTasks, executeAfterEventLoopIteration, hasTasks, next, parent, pendingTasks, register, registeredChannelsIterator, removeAfterEventLoopIterationTask

Methods inherited from class SingleThreadEventExecutor

addShutdownHook, addTask, awaitTermination, canSuspend, canSuspend, cleanup, confirmShutdown, deadlineNanos, delayNanos, execute, getAndIncrementBusyCycles, getAndIncrementIdleCycles, getAndResetAccumulatedActiveTimeNanos, getLastActivityTimeNanos, getNumOfRegisteredChannels, inEventLoop, interruptThread, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isShuttingDown, isSuspended, isSuspensionSupported, isTerminated, lazyExecute, newTaskQueue, newTaskQueue, peekTask, pollTask, pollTaskFrom, reject, reject, removeShutdownHook, removeTask, reportActiveIoTime, resetBusyCycles, resetIdleCycles, runAllTasks, runAllTasks, runAllTasksFrom, runScheduledAndExecutorTasks, shutdown, shutdownGracefully, takeTask, terminationFuture, threadProperties, trySuspend, updateLastExecutionTime, wakesUpForTask, wakeup

Methods inherited from class AbstractScheduledEventExecutor

afterScheduledTaskSubmitted, beforeScheduledTaskSubmitted, cancelScheduledTasks, deadlineToDelayNanos, delayNanos, fetchFromScheduledTaskQueue, getCurrentTimeNanos, hasScheduledTasks, initialNanoTime, nanoTime, nextScheduledTaskDeadlineNanos, nextScheduledTaskNano, pollScheduledTask, pollScheduledTask, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, ticker, validateScheduled

Methods inherited from class AbstractEventExecutor

iterator, newTaskFor, newTaskFor, runTask, safeExecute, shutdownGracefully, shutdownNow, submit, submit, submit

Methods inherited from class java.lang.Object

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

Methods inherited from interface EventExecutor

inEventLoop, inEventLoop, isExecutorThread, isSuspended, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, trySuspend

Methods inherited from interface EventExecutorGroup

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

Methods inherited from interface java.util.concurrent.Executor

execute

Methods inherited from interface java.util.concurrent.ExecutorService

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Details

parent

private final ThreadPerChannelEventLoopGroup parent

Deprecated.

ch

private Channel ch

Deprecated.

Constructor Details

ThreadPerChannelEventLoop

public ThreadPerChannelEventLoop(ThreadPerChannelEventLoopGroup parent)

Deprecated.

Method Details

register

public ChannelFuture register(ChannelPromise promise)

Deprecated.

Description copied from interface: EventLoopGroup

Register a Channel with this EventLoop using a ChannelFuture. The passed ChannelFuture will get notified once the registration was complete and also will get returned.

Specified by:

register in interface EventLoopGroup

Overrides:

register in class SingleThreadEventLoop

register

@Deprecated
public ChannelFuture register(Channel channel,
 ChannelPromise promise)

Deprecated.

Description copied from interface: EventLoopGroup

Register a Channel with this EventLoop. The passed ChannelFuture will get notified once the registration was complete and also will get returned.

Specified by:

register in interface EventLoopGroup

Overrides:

register in class SingleThreadEventLoop

run

protected void run()

Deprecated.

Description copied from class: SingleThreadEventExecutor

Runs the task-processing loop until SingleThreadEventExecutor.confirmShutdown() returns true.

Implementations must not let a Throwable thrown by a task escape this method: any uncaught Throwable terminates the executor (logged at WARN and surfaced via SingleThreadEventExecutor.terminationFuture()), at which point every Channel registered with this executor stops processing I/O and new task submissions are rejected. The supplied helpers - SingleThreadEventExecutor.runAllTasks(), SingleThreadEventExecutor.runAllTasks(long), and AbstractEventExecutor.safeExecute(Runnable) - catch Throwable for you; custom loops built on SingleThreadEventExecutor.pollTask() or SingleThreadEventExecutor.takeTask() are responsible for wrapping each task invocation accordingly.

Specified by:

run in class SingleThreadEventExecutor

deregister

protected void deregister()

Deprecated.

registeredChannels

public int registeredChannels()

Deprecated.

Description copied from class: SingleThreadEventLoop

Returns the number of Channels registered with this EventLoop or -1 if operation is not supported. The returned value is not guaranteed to be exact accurate and should be viewed as a best effort.

Overrides:

registeredChannels in class SingleThreadEventLoop