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

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

DEFAULT_MAX_PENDING_TASKS

构造器概要

构造器

构造器和说明
ThreadPerChannelEventLoop(ThreadPerChannelEventLoopGroup parent)

方法概要

方法

限定符和类型	方法和说明
protected void	deregister()
ChannelFuture	register(Channel channel, ChannelPromise promise) Register a Channel with this EventLoop.
protected void	run()

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

next, parent, register, wakesUpForTask

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

addShutdownHook, addTask, awaitTermination, cleanup, confirmShutdown, delayNanos, execute, hasTasks, inEventLoop, interruptThread, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isShuttingDown, isTerminated, newTaskQueue, newTaskQueue, peekTask, pendingTasks, pollTask, reject, removeShutdownHook, removeTask, runAllTasks, runAllTasks, shutdown, shutdownGracefully, takeTask, terminationFuture, threadProperties, updateLastExecutionTime, wakeup

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

cancelScheduledTasks, hasScheduledTasks, nanoTime, nextScheduledTaskNano, pollScheduledTask, pollScheduledTask, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay

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

inEventLoop, iterator, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, newTaskFor, newTaskFor, 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

构造器详细资料

ThreadPerChannelEventLoop

public ThreadPerChannelEventLoop(ThreadPerChannelEventLoopGroup parent)

方法详细资料

register

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()

指定者:

run 在类中 SingleThreadEventExecutor

deregister

protected void deregister()