Top Description Constructors Methods
io.netty.util.concurrent

public Class DefaultEventExecutorGroup

extends MultithreadEventExecutorGroup
Class Inheritance
Imports
java.util.concurrent.Executor, .ThreadFactory

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

Constructor Summary

AccessConstructor and Description
public
public
DefaultEventExecutorGroup(int
the number of threads that will be used by this instance.
nThreads
,
ThreadFactory
the ThreadFactory to use, or null if the default should be used.
threadFactory
)

Create a new instance.

public
DefaultEventExecutorGroup(int
the number of threads that will be used by this instance.
nThreads
,
ThreadFactory
the ThreadFactory to use, or null if the default should be used.
threadFactory
,
int
the maximum number of pending tasks before new tasks will be rejected.
maxPendingTasks
,
RejectedExecutionHandler rejectedHandler)

Create a new instance.

Method Summary

Modifier and TypeMethod and Description
protected EventExecutor
newChild(Executor executor, Object... args)

Implements abstract io.netty.util.concurrent.MultithreadEventExecutorGroup.newChild.

Create a new EventExecutor which will later then accessible via the next() method.
Inherited from io.netty.util.concurrent.MultithreadEventExecutorGroup:
awaitTerminationexecutorCountisShutdownisShuttingDownisTerminatediteratornewDefaultThreadFactorynextshutdownshutdownGracefullyterminationFuture

Constructor Detail

DefaultEventExecutorGroupback to summary
public DefaultEventExecutorGroup(int nThreads)
See Also
DefaultEventExecutorGroup(int, ThreadFactory)
DefaultEventExecutorGroupback to summary
public DefaultEventExecutorGroup(int nThreads, ThreadFactory threadFactory)

Create a new instance.

Parameters
nThreads:int

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

threadFactory:ThreadFactory

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

DefaultEventExecutorGroupback to summary
public DefaultEventExecutorGroup(int nThreads, ThreadFactory threadFactory, int maxPendingTasks, RejectedExecutionHandler rejectedHandler)

Create a new instance.

Parameters
nThreads:int

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

threadFactory:ThreadFactory

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

maxPendingTasks:int

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

rejectedHandler:RejectedExecutionHandler

the RejectedExecutionHandler to use.

Method Detail

newChildback to summary
protected EventExecutor newChild(Executor executor, Object... args) throws Exception

Implements abstract io.netty.util.concurrent.MultithreadEventExecutorGroup.newChild.

Doc from io.netty.util.concurrent.MultithreadEventExecutorGroup.newChild.

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

Annotations
@Override