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.构造器和说明 |
---|
OioEventLoopGroup()
Create a new
OioEventLoopGroup with no limit in place. |
OioEventLoopGroup(int maxChannels)
Create a new
OioEventLoopGroup . |
OioEventLoopGroup(int maxChannels,
java.util.concurrent.ThreadFactory threadFactory)
Create a new
OioEventLoopGroup . |
awaitTermination, isShutdown, isShuttingDown, isTerminated, iterator, newChild, next, register, register, 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
schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdownGracefully, shutdownNow, submit, submit, submit
public OioEventLoopGroup()
OioEventLoopGroup
with no limit in place.public OioEventLoopGroup(int maxChannels)
OioEventLoopGroup
.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(Channel, ChannelPromise)
method.
Use 0
to use no limitpublic OioEventLoopGroup(int maxChannels, java.util.concurrent.ThreadFactory threadFactory)
OioEventLoopGroup
.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(Channel, ChannelPromise)
method.
Use 0
to use no limitthreadFactory
- the ThreadFactory
used to create new Thread
instances that handle the
registered Channel
s