@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.NonWakeupRunnableAbstractEventExecutor.LazyRunnableDEFAULT_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, registeredChannelsIteratoraddShutdownHook, 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, wakeupafterScheduledTaskSubmitted, beforeScheduledTaskSubmitted, cancelScheduledTasks, deadlineToDelayNanos, getCurrentTimeNanos, hasScheduledTasks, initialNanoTime, nanoTime, nextScheduledTaskDeadlineNanos, nextScheduledTaskNano, pollScheduledTask, pollScheduledTask, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, validateScheduledinEventLoop, iterator, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, newTaskFor, newTaskFor, runTask, safeExecute, shutdownGracefully, shutdownNow, submit, submit, submitclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitinEventLoop, inEventLoop, newFailedFuture, newProgressivePromise, newPromise, newSucceededFutureisShuttingDown, iterator, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdown, shutdownGracefully, shutdownGracefully, shutdownNow, submit, submit, submit, terminationFutureawaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminatedforEach, spliteratorpublic ThreadPerChannelEventLoop(ThreadPerChannelEventLoopGroup parent)
public ChannelFuture register(ChannelPromise promise)
EventLoopGroupChannel 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 EventLoopGroupregister in class SingleThreadEventLoop@Deprecated public ChannelFuture register(Channel channel, ChannelPromise promise)
EventLoopGroupChannel with this EventLoop. The passed ChannelFuture
will get notified once the registration was complete and also will get returned.register in interface EventLoopGroupregister in class SingleThreadEventLoopprotected void run()
SingleThreadEventExecutorSingleThreadEventExecutor.taskQueuerun in class SingleThreadEventExecutorprotected void deregister()
public int registeredChannels()
SingleThreadEventLoopChannels 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 SingleThreadEventLoopCopyright © 2008–2025 The Netty Project. All rights reserved.