public abstract class MultithreadEventLoopGroup extends MultithreadEventExecutorGroup implements EventLoopGroup
EventLoopGroup implementations that handles their tasks with multiple threads at
the same time.| Modifier | Constructor and Description |
|---|---|
protected |
MultithreadEventLoopGroup(int nThreads,
Executor executor,
EventExecutorChooserFactory chooserFactory,
Object... args) |
protected |
MultithreadEventLoopGroup(int nThreads,
Executor executor,
Object... args) |
protected |
MultithreadEventLoopGroup(int nThreads,
ThreadFactory threadFactory,
Object... args) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract EventLoop |
newChild(Executor executor,
Object... args)
Create a new EventExecutor which will later then accessible via the
MultithreadEventExecutorGroup.next() method. |
protected ThreadFactory |
newDefaultThreadFactory() |
EventLoop |
next()
Returns one of the
EventExecutors managed by this EventExecutorGroup. |
ChannelFuture |
register(Channel channel)
|
ChannelFuture |
register(Channel channel,
ChannelPromise promise)
Deprecated.
|
ChannelFuture |
register(ChannelPromise promise)
|
awaitTermination, executorCount, isShutdown, isShuttingDown, isTerminated, iterator, shutdown, shutdownGracefully, terminationFutureexecute, invokeAll, invokeAll, invokeAny, invokeAny, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdownGracefully, shutdownNow, submit, submit, submitclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitisShuttingDown, iterator, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdown, shutdownGracefully, shutdownGracefully, shutdownNow, submit, submit, submit, terminationFutureawaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminatedforEach, spliteratorprotected MultithreadEventLoopGroup(int nThreads,
Executor executor,
Object... args)
protected MultithreadEventLoopGroup(int nThreads,
ThreadFactory threadFactory,
Object... args)
protected MultithreadEventLoopGroup(int nThreads,
Executor executor,
EventExecutorChooserFactory chooserFactory,
Object... args)
protected ThreadFactory newDefaultThreadFactory()
newDefaultThreadFactory in class MultithreadEventExecutorGrouppublic EventLoop next()
EventExecutorGroupEventExecutors managed by this EventExecutorGroup.next in interface EventLoopGroupnext in interface EventExecutorGroupnext in class MultithreadEventExecutorGroupprotected abstract EventLoop newChild(Executor executor, Object... args) throws Exception
MultithreadEventExecutorGroupMultithreadEventExecutorGroup.next() method. This method will be
called for each thread that will serve this MultithreadEventExecutorGroup.newChild in class MultithreadEventExecutorGroupExceptionpublic ChannelFuture register(Channel channel)
EventLoopGroupChannel with this EventLoop. The returned ChannelFuture
will get notified once the registration was complete.register in interface EventLoopGrouppublic ChannelFuture register(ChannelPromise promise)
EventLoopGroupChannel with this EventLoop using a ChannelFuture. The passed
ChannelFuture will get notified once the registration was complete and also will get returned.register in interface EventLoopGroup@Deprecated public ChannelFuture register(Channel channel, ChannelPromise promise)
EventLoopGroupChannel with this EventLoop. The passed ChannelFuture
will get notified once the registration was complete and also will get returned.register in interface EventLoopGroupCopyright © 2008–2017 The Netty Project. All rights reserved.