public final class EpollEventLoopGroup extends MultithreadEventLoopGroup
EventLoopGroup
which uses epoll under the covers. Because of this
it only works on linux.构造器和说明 |
---|
EpollEventLoopGroup()
Create a new instance using the default number of threads and the default
ThreadFactory . |
EpollEventLoopGroup(int nThreads)
Create a new instance using the specified number of threads and the default
ThreadFactory . |
EpollEventLoopGroup(int nThreads,
SelectStrategyFactory selectStrategyFactory)
Create a new instance using the specified number of threads and the default
ThreadFactory . |
EpollEventLoopGroup(int nThreads,
java.util.concurrent.ThreadFactory threadFactory)
Create a new instance using the specified number of threads and the given
ThreadFactory . |
EpollEventLoopGroup(int nThreads,
java.util.concurrent.ThreadFactory threadFactory,
int maxEventsAtOnce)
|
EpollEventLoopGroup(int nThreads,
java.util.concurrent.ThreadFactory threadFactory,
int maxEventsAtOnce,
SelectStrategyFactory selectStrategyFactory)
|
EpollEventLoopGroup(int nThreads,
java.util.concurrent.ThreadFactory threadFactory,
int maxEventsAtOnce,
SelectStrategyFactory selectStrategyFactory,
RejectedExecutionHandler rejectedExecutionHandler) |
EpollEventLoopGroup(int nThreads,
java.util.concurrent.ThreadFactory threadFactory,
SelectStrategyFactory selectStrategyFactory)
Create a new instance using the specified number of threads and the given
ThreadFactory . |
限定符和类型 | 方法和说明 |
---|---|
protected EventExecutor |
newChild(java.util.concurrent.ThreadFactory threadFactory,
java.lang.Object... args)
Create a new EventExecutor which will later then accessible via the
MultithreadEventExecutorGroup.next() method. |
void |
setIoRatio(int ioRatio)
Sets the percentage of the desired amount of time spent for I/O in the child event loops.
|
newDefaultThreadFactory, next, register, register
awaitTermination, children, executorCount, isShutdown, isShuttingDown, isTerminated, iterator, 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
isShuttingDown, iterator, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdown, shutdownGracefully, shutdownGracefully, shutdownNow, submit, submit, submit, terminationFuture
public EpollEventLoopGroup()
ThreadFactory
.public EpollEventLoopGroup(int nThreads)
ThreadFactory
.public EpollEventLoopGroup(int nThreads, SelectStrategyFactory selectStrategyFactory)
ThreadFactory
.public EpollEventLoopGroup(int nThreads, java.util.concurrent.ThreadFactory threadFactory)
ThreadFactory
.public EpollEventLoopGroup(int nThreads, java.util.concurrent.ThreadFactory threadFactory, SelectStrategyFactory selectStrategyFactory)
ThreadFactory
.@Deprecated public EpollEventLoopGroup(int nThreads, java.util.concurrent.ThreadFactory threadFactory, int maxEventsAtOnce)
ThreadFactory
and the given
maximal amount of epoll events to handle per epollWait(...).@Deprecated public EpollEventLoopGroup(int nThreads, java.util.concurrent.ThreadFactory threadFactory, int maxEventsAtOnce, SelectStrategyFactory selectStrategyFactory)
EpollEventLoopGroup(int)
, EpollEventLoopGroup(int, ThreadFactory)
, or
EpollEventLoopGroup(int, SelectStrategyFactory)
ThreadFactory
and the given
maximal amount of epoll events to handle per epollWait(...).public EpollEventLoopGroup(int nThreads, java.util.concurrent.ThreadFactory threadFactory, int maxEventsAtOnce, SelectStrategyFactory selectStrategyFactory, RejectedExecutionHandler rejectedExecutionHandler)
public void setIoRatio(int ioRatio)
50
, which means the event loop will try to spend the same amount of time for I/O as for non-I/O tasks.protected EventExecutor newChild(java.util.concurrent.ThreadFactory threadFactory, java.lang.Object... args) throws java.lang.Exception
MultithreadEventExecutorGroup
MultithreadEventExecutorGroup.next()
method. This method will be
called for each thread that will serve this MultithreadEventExecutorGroup
.newChild
在类中 MultithreadEventExecutorGroup
java.lang.Exception