io.netty.util.concurrent

类 DefaultEventExecutorGroup

java.lang.Object

io.netty.util.concurrent.AbstractEventExecutorGroup

io.netty.util.concurrent.MultithreadEventExecutorGroup

io.netty.util.concurrent.DefaultEventExecutorGroup

所有已实现的接口:

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

public class DefaultEventExecutorGroup
extends MultithreadEventExecutorGroup

Default implementation of MultithreadEventExecutorGroup which will use DefaultEventExecutor instances to handle the tasks.

构造器概要

构造器

构造器和说明
DefaultEventExecutorGroup(int nThreads)
DefaultEventExecutorGroup(int nThreads, java.util.concurrent.ThreadFactory threadFactory) Create a new instance.
DefaultEventExecutorGroup(int nThreads, java.util.concurrent.ThreadFactory threadFactory, int maxPendingTasks, RejectedExecutionHandler rejectedHandler) Create a new instance.

方法概要

限定符和类型	方法和说明
protected EventExecutor	newChild(java.util.concurrent.Executor executor, java.lang.Object... args) Create a new EventExecutor which will later then accessible via the MultithreadEventExecutorGroup.next() method.

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

awaitTermination, executorCount, isShutdown, isShuttingDown, isTerminated, iterator, newDefaultThreadFactory, next, 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

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

forEach, spliterator

构造器详细资料

DefaultEventExecutorGroup

public DefaultEventExecutorGroup(int nThreads)

另请参阅:

DefaultEventExecutorGroup(int, ThreadFactory)

DefaultEventExecutorGroup

public DefaultEventExecutorGroup(int nThreads,
                                 java.util.concurrent.ThreadFactory threadFactory)

Create a new instance.

参数:

nThreads - the number of threads that will be used by this instance.

threadFactory - the ThreadFactory to use, or null if the default should be used.

DefaultEventExecutorGroup

public DefaultEventExecutorGroup(int nThreads,
                                 java.util.concurrent.ThreadFactory threadFactory,
                                 int maxPendingTasks,
                                 RejectedExecutionHandler rejectedHandler)

Create a new instance.

参数:

nThreads - the number of threads that will be used by this instance.

threadFactory - the ThreadFactory to use, or null if the default should be used.

maxPendingTasks - the maximum number of pending tasks before new tasks will be rejected.

rejectedHandler - the RejectedExecutionHandler to use.

方法详细资料

newChild

protected EventExecutor 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