Top Description Constructors Methods
io.netty5.util.concurrent

public Class DefaultEventExecutorGroup

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

Default implementation of MultithreadEventExecutorGroup which will use SingleThreadEventExecutor 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

Inherited from io.netty5.util.concurrent.MultithreadEventExecutorGroup:
awaitTerminationexecutorCountexecutorsisShutdownisShuttingDownisTerminatediteratornewChildnextshutdownGracefullyterminationFuture

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.