@Deprecated 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.ChannelsReadOnlyIterator<T extends Channel>SingleThreadEventExecutor.NonWakeupRunnable AbstractEventExecutor.LazyRunnable DEFAULT_MAX_PENDING_TASKS | Constructor and Description |
|---|
ThreadPerChannelEventLoop (ThreadPerChannelEventLoopGroup parent)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
deregister ()
Deprecated.
|
ChannelFuture |
register (Channel channel,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
register (ChannelPromise promise)
Deprecated.
|
int |
registeredChannels ()
Deprecated.
|
protected void |
run ()
Deprecated.
Run the tasks in the
SingleThreadEventExecutor.taskQueue |
afterRunningAllTasks, executeAfterEventLoopIteration, hasTasks, next, parent, pendingTasks, register, registeredChannelsIterator addShutdownHook, addTask, awaitTermination, cleanup, confirmShutdown, deadlineNanos, delayNanos, execute, inEventLoop, interruptThread, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isShuttingDown, isTerminated, lazyExecute, newTaskQueue, newTaskQueue, peekTask, pollTask, pollTaskFrom, reject, reject, removeShutdownHook, removeTask, runAllTasks, runAllTasks, runAllTasksFrom, runScheduledAndExecutorTasks, shutdown, shutdownGracefully, takeTask, terminationFuture, threadProperties, updateLastExecutionTime, wakesUpForTask, wakeup afterScheduledTaskSubmitted, beforeScheduledTaskSubmitted, cancelScheduledTasks, deadlineToDelayNanos, getCurrentTimeNanos, hasScheduledTasks, initialNanoTime, nanoTime, nextScheduledTaskDeadlineNanos, nextScheduledTaskNano, pollScheduledTask, pollScheduledTask, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, validateScheduled inEventLoop, iterator, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, newTaskFor, newTaskFor, runTask, safeExecute, 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 awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated forEach, spliterator public ThreadPerChannelEventLoop(ThreadPerChannelEventLoopGroup parent)
public ChannelFuture register(ChannelPromise promise)
EventLoopGroup Channel with this EventLoop using a ChannelFuture. The passed
ChannelFuture will get notified once the registration was complete and also will get returned.register in interface EventLoopGroup register in class SingleThreadEventLoop @Deprecated 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()
SingleThreadEventExecutor SingleThreadEventExecutor.taskQueue run in class SingleThreadEventExecutor protected void deregister()
public int registeredChannels()
SingleThreadEventLoop 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.registeredChannels in class SingleThreadEventLoop Copyright © 2008–2025 The Netty Project. All rights reserved.