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, submit
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdownGracefully, shutdownNow, submit, submit, submit
invokeAll, invokeAll, invokeAny, invokeAny
public 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.IOException
public 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.IOException
public void shutdown()
shutdown
in interface io.netty.util.concurrent.EventExecutorGroup
shutdown
in interface ExecutorService
shutdown
in class io.netty.util.concurrent.AbstractEventExecutorGroup
public io.netty.channel.EventLoop next()
next
in interface io.netty.channel.EventLoopGroup
next
in interface io.netty.util.concurrent.EventExecutorGroup
public io.netty.channel.ChannelFuture register(io.netty.channel.Channel channel)
register
in interface io.netty.channel.EventLoopGroup
public io.netty.channel.ChannelFuture register(io.netty.channel.Channel channel, io.netty.channel.ChannelPromise promise)
register
in interface io.netty.channel.EventLoopGroup
public boolean isShuttingDown()
isShuttingDown
in interface io.netty.util.concurrent.EventExecutorGroup
public io.netty.util.concurrent.Future<?> shutdownGracefully(long quietPeriod, long timeout, TimeUnit unit)
shutdownGracefully
in interface io.netty.util.concurrent.EventExecutorGroup
public io.netty.util.concurrent.Future<?> terminationFuture()
terminationFuture
in interface io.netty.util.concurrent.EventExecutorGroup
public Iterator<io.netty.util.concurrent.EventExecutor> iterator()
public boolean isShutdown()
isShutdown
in interface ExecutorService
public boolean isTerminated()
isTerminated
in interface ExecutorService
public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException
awaitTermination
in interface ExecutorService
InterruptedException
Copyright © 2013–2014 JBoss, a division of Red Hat. All rights reserved.