Class DefaultEventExecutorGroup
java.lang.Object
io.netty.util.concurrent.AbstractEventExecutorGroup
io.netty.util.concurrent.MultithreadEventExecutorGroup
io.netty.util.concurrent.DefaultEventExecutorGroup
- All Implemented Interfaces:
EventExecutorGroup, Iterable<EventExecutor>, Executor, ExecutorService, ScheduledExecutorService
Default implementation of
MultithreadEventExecutorGroup which will use DefaultEventExecutor instances
to handle the tasks.-
Constructor Summary
ConstructorsConstructorDescriptionDefaultEventExecutorGroup(int nThreads) DefaultEventExecutorGroup(int nThreads, ThreadFactory threadFactory) Create a new instance.DefaultEventExecutorGroup(int nThreads, ThreadFactory threadFactory, int maxPendingTasks, RejectedExecutionHandler rejectedHandler) Create a new instance. -
Method Summary
Modifier and TypeMethodDescriptionprotected EventExecutorCreate a new EventExecutor which will later then accessible via theMultithreadEventExecutorGroup.next()method.Methods inherited from class MultithreadEventExecutorGroup
activeExecutorCount, awaitTermination, executorCount, executorUtilizations, isShutdown, isShuttingDown, isTerminated, iterator, newDefaultThreadFactory, next, shutdown, shutdownGracefully, terminationFutureMethods inherited from class AbstractEventExecutorGroup
execute, invokeAll, invokeAll, invokeAny, invokeAny, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdownGracefully, shutdownNow, submit, submit, submitMethods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface EventExecutorGroup
tickerMethods inherited from interface Iterable
forEach, spliterator
-
Constructor Details
-
DefaultEventExecutorGroup
public DefaultEventExecutorGroup(int nThreads) -
DefaultEventExecutorGroup
Create a new instance.- Parameters:
nThreads- the number of threads that will be used by this instance.threadFactory- the ThreadFactory to use, ornullif the default should be used.
-
DefaultEventExecutorGroup
public DefaultEventExecutorGroup(int nThreads, ThreadFactory threadFactory, int maxPendingTasks, RejectedExecutionHandler rejectedHandler) Create a new instance.- Parameters:
nThreads- the number of threads that will be used by this instance.threadFactory- the ThreadFactory to use, ornullif the default should be used.maxPendingTasks- the maximum number of pending tasks before new tasks will be rejected.rejectedHandler- theRejectedExecutionHandlerto use.
-
-
Method Details
-
newChild
Description copied from class:MultithreadEventExecutorGroupCreate a new EventExecutor which will later then accessible via theMultithreadEventExecutorGroup.next()method. This method will be called for each thread that will serve thisMultithreadEventExecutorGroup.- Specified by:
newChildin classMultithreadEventExecutorGroup- Throws:
Exception
-