public class DefaultEventExecutorGroup extends MultithreadEventExecutorGroup
MultithreadEventExecutorGroup
which will use DefaultEventExecutor
instances
to handle the tasks.Constructor and Description |
---|
DefaultEventExecutorGroup(int nThreads) |
DefaultEventExecutorGroup(int nThreads,
ThreadFactory threadFactory)
Create a new instance.
|
DefaultEventExecutorGroup(int nThreads,
ThreadFactory threadFactory,
int maxPendingTasks,
RejectedExecutionHandler rejectedHandler)
Create a new instance.
|
Modifier and Type | Method and Description |
---|---|
protected EventExecutor |
newChild(Executor executor,
Object... args)
Create a new EventExecutor which will later then accessible via the
MultithreadEventExecutorGroup.next() method. |
awaitTermination, executorCount, isShutdown, isShuttingDown, isTerminated, iterator, newDefaultThreadFactory, next, shutdown, shutdownGracefully, terminationFuture
execute, invokeAll, invokeAll, invokeAny, invokeAny, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdownGracefully, shutdownNow, submit, submit, submit
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
public DefaultEventExecutorGroup(int nThreads)
public DefaultEventExecutorGroup(int nThreads, ThreadFactory threadFactory)
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.public DefaultEventExecutorGroup(int nThreads, ThreadFactory threadFactory, int maxPendingTasks, RejectedExecutionHandler rejectedHandler)
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.protected EventExecutor newChild(Executor executor, Object... args) throws Exception
MultithreadEventExecutorGroup
MultithreadEventExecutorGroup.next()
method. This method will be
called for each thread that will serve this MultithreadEventExecutorGroup
.newChild
in class MultithreadEventExecutorGroup
Exception
Copyright © 2008–2019 The Netty Project. All rights reserved.