@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
Channel
s 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–2024 The Netty Project. All rights reserved.