Top Description Fields Constructors Methods
io.netty.channel

public abstract Class MultithreadEventLoopGroup

extends MultithreadEventExecutorGroup
implements EventLoopGroup
Class Inheritance
All Implemented Interfaces
io.netty.channel.EventLoopGroup, io.netty.util.concurrent.EventExecutorGroup, java.lang.Iterable, java.util.concurrent.ScheduledExecutorService, java.util.concurrent.ExecutorService, java.lang.AutoCloseable, java.util.concurrent.Executor
Known Direct Subclasses
io.netty.channel.DefaultEventLoopGroup, io.netty.channel.nio.NioEventLoopGroup
Imports
io.netty.util.NettyRuntime, io.netty.util.concurrent.DefaultThreadFactory, .EventExecutorChooserFactory, .MultithreadEventExecutorGroup, io.netty.util.internal.SystemPropertyUtil, io.netty.util.internal.logging.InternalLogger, .InternalLoggerFactory, java.util.concurrent.Executor, .ThreadFactory
Abstract base class for EventLoopGroup implementations that handles their tasks with multiple threads at the same time.

Field Summary

Modifier and TypeField and Description
private static final int
DEFAULT_EVENT_LOOP_THREADS

private static final InternalLogger
logger

Constructor Summary

AccessConstructor and Description
protected
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)

Method Summary

Modifier and TypeMethod and Description
protected abstract EventLoop
newChild(Executor executor, Object... args)

Implements abstract io.netty.util.concurrent.MultithreadEventExecutorGroup.newChild.

Create a new EventExecutor which will later then accessible via the next() method.
protected ThreadFactory
newDefaultThreadFactory()

Overrides io.netty.util.concurrent.MultithreadEventExecutorGroup.newDefaultThreadFactory.

public EventLoop
next()

Overrides io.netty.util.concurrent.MultithreadEventExecutorGroup.next.

Implements io.netty.channel.EventLoopGroup.next, io.netty.util.concurrent.EventExecutorGroup.next.

Return the next EventLoop to use
public ChannelFuture
register(Channel channel)

Implements io.netty.channel.EventLoopGroup.register.

Register a Channel with this EventLoop.
public ChannelFuture
register(ChannelPromise promise)

Implements io.netty.channel.EventLoopGroup.register.

Register a Channel with this EventLoop using a ChannelFuture.
public ChannelFuture
register(Channel channel, ChannelPromise promise)

Implements io.netty.channel.EventLoopGroup.register.

Deprecated
Register a Channel with this EventLoop.
Inherited from io.netty.util.concurrent.MultithreadEventExecutorGroup:
awaitTerminationexecutorCountisShutdownisShuttingDownisTerminatediteratorshutdownshutdownGracefullyterminationFuture

Field Detail

DEFAULT_EVENT_LOOP_THREADSback to summary
private static final int DEFAULT_EVENT_LOOP_THREADS
loggerback to summary
private static final InternalLogger logger

Constructor Detail

MultithreadEventLoopGroupback to summary
protected MultithreadEventLoopGroup(int nThreads, Executor executor, Object... args)
See Also
MultithreadEventExecutorGroup#MultithreadEventExecutorGroup(int, Executor, Object...)
MultithreadEventLoopGroupback to summary
protected MultithreadEventLoopGroup(int nThreads, ThreadFactory threadFactory, Object... args)
See Also
MultithreadEventExecutorGroup#MultithreadEventExecutorGroup(int, ThreadFactory, Object...)
MultithreadEventLoopGroupback to summary
protected MultithreadEventLoopGroup(int nThreads, Executor executor, EventExecutorChooserFactory chooserFactory, Object... args)
See Also
MultithreadEventExecutorGroup#MultithreadEventExecutorGroup(int, Executor, EventExecutorChooserFactory, Object...)

Method Detail

newChildback to summary
protected abstract EventLoop newChild(Executor executor, Object... args) throws Exception

Implements abstract io.netty.util.concurrent.MultithreadEventExecutorGroup.newChild.

Doc from io.netty.util.concurrent.MultithreadEventExecutorGroup.newChild.

Create a new EventExecutor which will later then accessible via the next() method. This method will be called for each thread that will serve this MultithreadEventExecutorGroup.

Annotations
@Override
newDefaultThreadFactoryback to summary
protected ThreadFactory newDefaultThreadFactory()

Overrides io.netty.util.concurrent.MultithreadEventExecutorGroup.newDefaultThreadFactory.

Annotations
@Override
nextback to summary
public EventLoop next()

Overrides io.netty.util.concurrent.MultithreadEventExecutorGroup.next.

Implements io.netty.channel.EventLoopGroup.next, io.netty.util.concurrent.EventExecutorGroup.next.

Doc from io.netty.channel.EventLoopGroup.next.

Return the next EventLoop to use

Annotations
@Override
registerback to summary
public ChannelFuture register(Channel channel)

Implements io.netty.channel.EventLoopGroup.register.

Doc from io.netty.channel.EventLoopGroup.register.

Register a Channel with this EventLoop. The returned ChannelFuture will get notified once the registration was complete.

Annotations
@Override
registerback to summary
public ChannelFuture register(ChannelPromise promise)

Implements io.netty.channel.EventLoopGroup.register.

Doc from io.netty.channel.EventLoopGroup.register.

Register a Channel with this EventLoop using a ChannelFuture. The passed ChannelFuture will get notified once the registration was complete and also will get returned.

Annotations
@Override
registerback to summary
public ChannelFuture register(Channel channel, ChannelPromise promise)

Implements io.netty.channel.EventLoopGroup.register.

Doc from io.netty.channel.EventLoopGroup.register.

Deprecated

Register a Channel with this EventLoop. The passed ChannelFuture will get notified once the registration was complete and also will get returned.

Annotations
@Deprecated
@Override