io.netty.channel

类 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

所有已实现的接口:

EventLoop, EventLoopGroup, EventExecutor, EventExecutorGroup, OrderedEventExecutor, java.lang.Iterable<EventExecutor>, java.util.concurrent.Executor, java.util.concurrent.ExecutorService, java.util.concurrent.ScheduledExecutorService

已过时。

this will be remove in the next-major release.

@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.

嵌套类概要

从类继承的嵌套类/接口 io.netty.channel.SingleThreadEventLoop

SingleThreadEventLoop.ChannelsReadOnlyIterator<T extends Channel>

从类继承的嵌套类/接口 io.netty.util.concurrent.SingleThreadEventExecutor

SingleThreadEventExecutor.NonWakeupRunnable

从类继承的嵌套类/接口 io.netty.util.concurrent.AbstractEventExecutor

AbstractEventExecutor.LazyRunnable

字段概要

从类继承的字段 io.netty.channel.SingleThreadEventLoop

DEFAULT_MAX_PENDING_TASKS

构造器概要

构造器

构造器和说明
ThreadPerChannelEventLoop(ThreadPerChannelEventLoopGroup parent) 已过时。

方法概要

限定符和类型	方法和说明
protected void	deregister() 已过时。
ChannelFuture	register(Channel channel, ChannelPromise promise) 已过时。
ChannelFuture	register(ChannelPromise promise) 已过时。 Register a Channel with this EventLoop using a ChannelFuture.
int	registeredChannels() 已过时。 Returns the number of Channels registered with this EventLoop or -1 if operation is not supported.
protected void	run() 已过时。 Run the tasks in the SingleThreadEventExecutor.taskQueue

从类继承的方法 io.netty.channel.SingleThreadEventLoop

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

从类继承的方法 io.netty.util.concurrent.SingleThreadEventExecutor

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

从类继承的方法 io.netty.util.concurrent.AbstractScheduledEventExecutor

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

从类继承的方法 io.netty.util.concurrent.AbstractEventExecutor

inEventLoop, iterator, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, newTaskFor, newTaskFor, runTask, safeExecute, shutdownGracefully, shutdownNow, submit, submit, submit

从类继承的方法 java.lang.Object

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

从接口继承的方法 io.netty.util.concurrent.EventExecutor

inEventLoop, inEventLoop, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture

从接口继承的方法 io.netty.util.concurrent.EventExecutorGroup

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

从接口继承的方法 java.util.concurrent.ExecutorService

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

从接口继承的方法 java.util.concurrent.Executor

execute

从接口继承的方法 java.lang.Iterable

forEach, spliterator

构造器详细资料

ThreadPerChannelEventLoop

public ThreadPerChannelEventLoop(ThreadPerChannelEventLoopGroup parent)

已过时。

方法详细资料

register

public ChannelFuture register(ChannelPromise promise)

已过时。

从接口复制的说明: 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.

指定者:

register 在接口中 EventLoopGroup

覆盖:

register 在类中 SingleThreadEventLoop

register

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

已过时。

从接口复制的说明: EventLoopGroup

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

指定者:

register 在接口中 EventLoopGroup

覆盖:

register 在类中 SingleThreadEventLoop

run

protected void run()

已过时。

从类复制的说明: SingleThreadEventExecutor

Run the tasks in the SingleThreadEventExecutor.taskQueue

指定者:

run 在类中 SingleThreadEventExecutor

deregister

protected void deregister()

已过时。

registeredChannels

public int registeredChannels()

已过时。

从类复制的说明: 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.

覆盖:

registeredChannels 在类中 SingleThreadEventLoop