io.netty.channel

类 MultithreadEventLoopGroup

java.lang.Object

io.netty.util.concurrent.AbstractEventExecutorGroup

io.netty.util.concurrent.MultithreadEventExecutorGroup

io.netty.channel.MultithreadEventLoopGroup

所有已实现的接口:

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

直接已知子类:

DefaultEventLoopGroup, EpollEventLoopGroup, KQueueEventLoopGroup, NioEventLoopGroup

public abstract class MultithreadEventLoopGroup
extends MultithreadEventExecutorGroup
implements EventLoopGroup

Abstract base class for EventLoopGroup implementations that handles their tasks with multiple threads at the same time.

构造器概要

构造器

限定符	构造器和说明
protected	MultithreadEventLoopGroup(int nThreads, java.util.concurrent.Executor executor, EventExecutorChooserFactory chooserFactory, java.lang.Object... args)
protected	MultithreadEventLoopGroup(int nThreads, java.util.concurrent.Executor executor, java.lang.Object... args)
protected	MultithreadEventLoopGroup(int nThreads, java.util.concurrent.ThreadFactory threadFactory, java.lang.Object... args)

方法概要

限定符和类型	方法和说明
protected abstract EventLoop	newChild(java.util.concurrent.Executor executor, java.lang.Object... args) Create a new EventExecutor which will later then accessible via the MultithreadEventExecutorGroup.next() method.
protected java.util.concurrent.ThreadFactory	newDefaultThreadFactory()
EventLoop	next() Returns one of the EventExecutors managed by this EventExecutorGroup.
ChannelFuture	register(Channel channel) Register a Channel with this EventLoop.
ChannelFuture	register(Channel channel, ChannelPromise promise) 已过时。
ChannelFuture	register(ChannelPromise promise) Register a Channel with this EventLoop using a ChannelFuture.

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

awaitTermination, executorCount, isShutdown, isShuttingDown, isTerminated, iterator, shutdown, shutdownGracefully, terminationFuture

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

execute, invokeAll, invokeAll, invokeAny, invokeAny, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdownGracefully, shutdownNow, submit, submit, submit

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

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

从接口继承的方法 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

构造器详细资料

MultithreadEventLoopGroup

protected MultithreadEventLoopGroup(int nThreads,
                                    java.util.concurrent.Executor executor,
                                    java.lang.Object... args)

另请参阅:

MultithreadEventExecutorGroup.MultithreadEventExecutorGroup(int, Executor, Object...)

MultithreadEventLoopGroup

protected MultithreadEventLoopGroup(int nThreads,
                                    java.util.concurrent.ThreadFactory threadFactory,
                                    java.lang.Object... args)

另请参阅:

MultithreadEventExecutorGroup.MultithreadEventExecutorGroup(int, ThreadFactory, Object...)

MultithreadEventLoopGroup

protected MultithreadEventLoopGroup(int nThreads,
                                    java.util.concurrent.Executor executor,
                                    EventExecutorChooserFactory chooserFactory,
                                    java.lang.Object... args)

另请参阅:

MultithreadEventExecutorGroup.MultithreadEventExecutorGroup(int, Executor, EventExecutorChooserFactory, Object...)

方法详细资料

newDefaultThreadFactory

protected java.util.concurrent.ThreadFactory newDefaultThreadFactory()

覆盖:

newDefaultThreadFactory 在类中 MultithreadEventExecutorGroup

next

public EventLoop next()

从接口复制的说明: EventExecutorGroup

Returns one of the EventExecutors managed by this EventExecutorGroup.

指定者:

next 在接口中 EventLoopGroup

指定者:

next 在接口中 EventExecutorGroup

覆盖:

next 在类中 MultithreadEventExecutorGroup

newChild

protected abstract EventLoop newChild(java.util.concurrent.Executor executor,
                                      java.lang.Object... args)
                               throws java.lang.Exception

从类复制的说明: MultithreadEventExecutorGroup

Create a new EventExecutor which will later then accessible via the MultithreadEventExecutorGroup.next() method. This method will be called for each thread that will serve this MultithreadEventExecutorGroup.

指定者:

newChild 在类中 MultithreadEventExecutorGroup

抛出:

java.lang.Exception

register

public ChannelFuture register(Channel channel)

从接口复制的说明: EventLoopGroup

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

指定者:

register 在接口中 EventLoopGroup

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

@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