Package io.netty.channel
Class DefaultEventLoopGroup
java.lang.Object
io.netty.util.concurrent.AbstractEventExecutorGroup
io.netty.util.concurrent.MultithreadEventExecutorGroup
io.netty.channel.MultithreadEventLoopGroup
io.netty.channel.DefaultEventLoopGroup
- All Implemented Interfaces:
EventLoopGroup
,EventExecutorGroup
,AutoCloseable
,Iterable<EventExecutor>
,Executor
,ExecutorService
,ScheduledExecutorService
- Direct Known Subclasses:
LocalEventLoopGroup
MultithreadEventLoopGroup
which must be used for the local transport.-
Constructor Summary
ConstructorsConstructorDescriptionCreate a new instance with the default number of threads.DefaultEventLoopGroup
(int nThreads) Create a new instanceDefaultEventLoopGroup
(int nThreads, Executor executor) Create a new instanceDefaultEventLoopGroup
(int nThreads, ThreadFactory threadFactory) Create a new instanceDefaultEventLoopGroup
(ThreadFactory threadFactory) Create a new instance with the default number of threads and the givenThreadFactory
. -
Method Summary
Modifier and TypeMethodDescriptionprotected EventLoop
Create a new EventExecutor which will later then accessible via theMultithreadEventExecutorGroup.next()
method.Methods inherited from class io.netty.channel.MultithreadEventLoopGroup
newDefaultThreadFactory, next, register, register, register
Methods inherited from class io.netty.util.concurrent.MultithreadEventExecutorGroup
awaitTermination, executorCount, isShutdown, isShuttingDown, isTerminated, iterator, 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 io.netty.util.concurrent.EventExecutorGroup
isShuttingDown, iterator, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdown, shutdownGracefully, shutdownGracefully, shutdownNow, submit, submit, submit, terminationFuture
Methods inherited from interface java.util.concurrent.ExecutorService
awaitTermination, close, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated
Methods inherited from interface java.lang.Iterable
forEach, spliterator
-
Constructor Details
-
DefaultEventLoopGroup
public DefaultEventLoopGroup()Create a new instance with the default number of threads. -
DefaultEventLoopGroup
public DefaultEventLoopGroup(int nThreads) Create a new instance- Parameters:
nThreads
- the number of threads to use
-
DefaultEventLoopGroup
Create a new instance with the default number of threads and the givenThreadFactory
.- Parameters:
threadFactory
- theThreadFactory
ornull
to use the default
-
DefaultEventLoopGroup
Create a new instance- Parameters:
nThreads
- the number of threads to usethreadFactory
- theThreadFactory
ornull
to use the default
-
DefaultEventLoopGroup
Create a new instance- Parameters:
nThreads
- the number of threads to useexecutor
- the Executor to use, ornull
if the default should be used.
-
-
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 classMultithreadEventLoopGroup
- Throws:
Exception
-