io.netty.channel.oio

Class OioEventLoopGroup

java.lang.Object

io.netty.util.concurrent.AbstractEventExecutorGroup

io.netty.channel.ThreadPerChannelEventLoopGroup

io.netty.channel.oio.OioEventLoopGroup

All Implemented Interfaces:

EventLoopGroup, EventExecutorGroup, Iterable<EventExecutor>, Executor, ExecutorService, ScheduledExecutorService

public class OioEventLoopGroup
extends ThreadPerChannelEventLoopGroup

EventLoopGroup which is used to handle OIO Channel's. Each Channel will be handled by its own EventLoop to not block others.

Constructor Summary

Constructors

Constructor and Description
OioEventLoopGroup() Create a new OioEventLoopGroup with no limit in place.
OioEventLoopGroup(int maxChannels) Create a new OioEventLoopGroup.
OioEventLoopGroup(int maxChannels, Executor executor) Create a new OioEventLoopGroup.
OioEventLoopGroup(int maxChannels, ThreadFactory threadFactory) Create a new OioEventLoopGroup.

Method Summary

Methods inherited from class io.netty.channel.ThreadPerChannelEventLoopGroup

awaitTermination, isShutdown, isShuttingDown, isTerminated, iterator, newChild, next, register, register, register, 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

schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdownGracefully, shutdownNow, submit, submit, submit

Methods inherited from interface java.util.concurrent.ExecutorService

invokeAll, invokeAll, invokeAny, invokeAny

Methods inherited from interface java.util.concurrent.Executor

execute

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

OioEventLoopGroup

public OioEventLoopGroup()

Create a new OioEventLoopGroup with no limit in place.

OioEventLoopGroup

public OioEventLoopGroup(int maxChannels)

Create a new OioEventLoopGroup.

Parameters:

maxChannels - the maximum number of channels to handle with this instance. Once you try to register a new Channel and the maximum is exceed it will throw an ChannelException on the ThreadPerChannelEventLoopGroup.register(Channel) and ThreadPerChannelEventLoopGroup.register(ChannelPromise) method. Use 0 to use no limit

OioEventLoopGroup

public OioEventLoopGroup(int maxChannels,
                         Executor executor)

Create a new OioEventLoopGroup.

Parameters:

maxChannels - the maximum number of channels to handle with this instance. Once you try to register a new Channel and the maximum is exceed it will throw an ChannelException on the ThreadPerChannelEventLoopGroup.register(Channel) and ThreadPerChannelEventLoopGroup.register(ChannelPromise) method. Use 0 to use no limit

executor - the Executor used to create new Thread instances that handle the registered Channels

OioEventLoopGroup

public OioEventLoopGroup(int maxChannels,
                         ThreadFactory threadFactory)

Create a new OioEventLoopGroup.

Parameters:

maxChannels - the maximum number of channels to handle with this instance. Once you try to register a new Channel and the maximum is exceed it will throw an ChannelException on the ThreadPerChannelEventLoopGroup.register(Channel) and ThreadPerChannelEventLoopGroup.register(ChannelPromise) method. Use 0 to use no limit

threadFactory - the ThreadFactory used to create new Thread instances that handle the registered Channels