Package io.netty.util.concurrent
Class DefaultEventExecutorGroup
java.lang.Object
io.netty.util.concurrent.AbstractEventExecutorGroup
io.netty.util.concurrent.MultithreadEventExecutorGroup
io.netty.util.concurrent.DefaultEventExecutorGroup
- All Implemented Interfaces:
EventExecutorGroup
,AutoCloseable
,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 EventExecutor
Create a new EventExecutor which will later then accessible via theMultithreadEventExecutorGroup.next()
method.Methods inherited from class io.netty.util.concurrent.MultithreadEventExecutorGroup
awaitTermination, executorCount, isShutdown, isShuttingDown, isTerminated, iterator, newDefaultThreadFactory, next, shutdown, shutdownGracefully, terminationFuture
Methods inherited from class io.netty.util.concurrent.AbstractEventExecutorGroup
execute, invokeAll, invokeAll, invokeAny, invokeAny, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdownGracefully, shutdownNow, submit, submit, submit
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface java.util.concurrent.ExecutorService
close
Methods inherited from interface java.lang.Iterable
forEach, spliterator
-
Constructor Details
-
DefaultEventExecutorGroup
public DefaultEventExecutorGroup(int nThreads) - See Also:
-
DefaultEventExecutorGroup
Create a new instance.- Parameters:
nThreads
- the number of threads that will be used by this instance.threadFactory
- the ThreadFactory to use, ornull
if 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, ornull
if the default should be used.maxPendingTasks
- the maximum number of pending tasks before new tasks will be rejected.rejectedHandler
- theRejectedExecutionHandler
to use.
-
-
Method Details
-
newChild
Description copied from class:MultithreadEventExecutorGroup
Create 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:
newChild
in classMultithreadEventExecutorGroup
- Throws:
Exception
-