public final class XnioEventLoopGroup
extends io.netty.util.concurrent.AbstractEventExecutorGroup
implements io.netty.channel.EventLoopGroup
EventLoopGroup implementation which uses a XnioWorker under the covers. This means all operations
will be performed by it.| Constructor and Description |
|---|
XnioEventLoopGroup()
Create a new
XnioEventLoopGroup which creates a new XnioWorker
by itself and use it for all operations. |
XnioEventLoopGroup(int numThreads)
Create a new
XnioEventLoopGroup which creates a new XnioWorker by itself and use it for all
operations. |
XnioEventLoopGroup(org.xnio.XnioWorker worker)
Create a new
XnioEventLoopGroup using the provided XnioWorker. |
| Modifier and Type | Method and Description |
|---|---|
boolean |
awaitTermination(long timeout,
TimeUnit unit) |
boolean |
isShutdown() |
boolean |
isShuttingDown() |
boolean |
isTerminated() |
Iterator<io.netty.util.concurrent.EventExecutor> |
iterator() |
io.netty.channel.EventLoop |
next() |
io.netty.channel.ChannelFuture |
register(io.netty.channel.Channel channel) |
io.netty.channel.ChannelFuture |
register(io.netty.channel.Channel channel,
io.netty.channel.ChannelPromise promise) |
void |
shutdown() |
io.netty.util.concurrent.Future<?> |
shutdownGracefully(long quietPeriod,
long timeout,
TimeUnit unit) |
io.netty.util.concurrent.Future<?> |
terminationFuture() |
execute, invokeAll, invokeAll, invokeAny, invokeAny, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdownGracefully, shutdownNow, submit, submit, submitclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitschedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdownGracefully, shutdownNow, submit, submit, submitinvokeAll, invokeAll, invokeAny, invokeAnyforEach, spliteratorpublic XnioEventLoopGroup(org.xnio.XnioWorker worker)
XnioEventLoopGroup using the provided XnioWorker.public XnioEventLoopGroup()
throws IOException
XnioEventLoopGroup which creates a new XnioWorker
by itself and use it for all operations.IOExceptionpublic XnioEventLoopGroup(int numThreads)
throws IOException
XnioEventLoopGroup which creates a new XnioWorker by itself and use it for all
operations. Using the given number of Threads to handle the IO.IOExceptionpublic void shutdown()
shutdown in interface io.netty.util.concurrent.EventExecutorGroupshutdown in interface ExecutorServiceshutdown in class io.netty.util.concurrent.AbstractEventExecutorGrouppublic io.netty.channel.EventLoop next()
next in interface io.netty.channel.EventLoopGroupnext in interface io.netty.util.concurrent.EventExecutorGrouppublic io.netty.channel.ChannelFuture register(io.netty.channel.Channel channel)
register in interface io.netty.channel.EventLoopGrouppublic io.netty.channel.ChannelFuture register(io.netty.channel.Channel channel,
io.netty.channel.ChannelPromise promise)
register in interface io.netty.channel.EventLoopGrouppublic boolean isShuttingDown()
isShuttingDown in interface io.netty.util.concurrent.EventExecutorGrouppublic io.netty.util.concurrent.Future<?> shutdownGracefully(long quietPeriod,
long timeout,
TimeUnit unit)
shutdownGracefully in interface io.netty.util.concurrent.EventExecutorGrouppublic io.netty.util.concurrent.Future<?> terminationFuture()
terminationFuture in interface io.netty.util.concurrent.EventExecutorGrouppublic Iterator<io.netty.util.concurrent.EventExecutor> iterator()
public boolean isShutdown()
isShutdown in interface ExecutorServicepublic boolean isTerminated()
isTerminated in interface ExecutorServicepublic boolean awaitTermination(long timeout,
TimeUnit unit)
throws InterruptedException
awaitTermination in interface ExecutorServiceInterruptedExceptionCopyright © 2013–2014 JBoss, a division of Red Hat. All rights reserved.