Package io.netty.incubator.channel.uring
Class IOUringEventLoopGroup
java.lang.Object
io.netty.util.concurrent.AbstractEventExecutorGroup
io.netty.util.concurrent.MultithreadEventExecutorGroup
io.netty.channel.MultithreadEventLoopGroup
io.netty.incubator.channel.uring.IOUringEventLoopGroup
- All Implemented Interfaces:
io.netty.channel.EventLoopGroup
,io.netty.util.concurrent.EventExecutorGroup
,Iterable<io.netty.util.concurrent.EventExecutor>
,Executor
,ExecutorService
,ScheduledExecutorService
public final class IOUringEventLoopGroup
extends io.netty.channel.MultithreadEventLoopGroup
-
Constructor Summary
ConstructorsModifierConstructorDescriptionCreate a new instance using the default number of threads and the defaultThreadFactory
.IOUringEventLoopGroup
(int nThreads) Create a new instance using the specified number of threads and the defaultThreadFactory
.IOUringEventLoopGroup
(int nThreads, Executor executor) Create a new instance using the specified number of threads and the givenExecutor
.IOUringEventLoopGroup
(int nThreads, Executor executor, int ringsize, int iosqeAsyncThreshold) Create a new instance using the specified number of threads, the givenExecutor
, the given size of the used ringbuffer and a threshold of registered FDs after which IOSEQ_ASYNC should be used for IO operations.private
IOUringEventLoopGroup
(int nThreads, Executor executor, io.netty.util.concurrent.EventExecutorChooserFactory chooserFactory, int ringSize, int iosqeAsyncThreshold, io.netty.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler) private
IOUringEventLoopGroup
(int nThreads, Executor executor, io.netty.util.concurrent.EventExecutorChooserFactory chooserFactory, int ringSize, int iosqeAsyncThreshold, io.netty.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler, io.netty.channel.EventLoopTaskQueueFactory queueFactory) IOUringEventLoopGroup
(int nThreads, ThreadFactory threadFactory) Create a new instance using the specified number of threads and the givenThreadFactory
.IOUringEventLoopGroup
(int nThreads, ThreadFactory threadFactory, int ringSize, int iosqeAsyncThreshold) Create a new instance using the specified number of threads, the givenThreadFactory
, the given size of the used ringbuffer and a threshold of registered FDs after which IOSEQ_ASYNC should be used for IO operations.IOUringEventLoopGroup
(ThreadFactory threadFactory) Create a new instance using the default number of threads and the givenThreadFactory
. -
Method Summary
Methods inherited from class io.netty.channel.MultithreadEventLoopGroup
newDefaultThreadFactory, next, register, register, register
Methods inherited from class io.netty.util.concurrent.MultithreadEventExecutorGroup
awaitTermination, executorCount, isShutdown, isShuttingDown, isTerminated, iterator, 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
isShuttingDown, iterator, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdown, shutdownGracefully, shutdownGracefully, shutdownNow, submit, submit, submit, terminationFuture, ticker
Methods inherited from interface java.util.concurrent.ExecutorService
awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated
Methods inherited from interface java.lang.Iterable
forEach, spliterator
-
Constructor Details
-
IOUringEventLoopGroup
public IOUringEventLoopGroup()Create a new instance using the default number of threads and the defaultThreadFactory
. -
IOUringEventLoopGroup
public IOUringEventLoopGroup(int nThreads) Create a new instance using the specified number of threads and the defaultThreadFactory
. -
IOUringEventLoopGroup
Create a new instance using the default number of threads and the givenThreadFactory
. -
IOUringEventLoopGroup
Create a new instance using the specified number of threads and the givenThreadFactory
. -
IOUringEventLoopGroup
Create a new instance using the specified number of threads and the givenExecutor
. -
IOUringEventLoopGroup
public IOUringEventLoopGroup(int nThreads, ThreadFactory threadFactory, int ringSize, int iosqeAsyncThreshold) Create a new instance using the specified number of threads, the givenThreadFactory
, the given size of the used ringbuffer and a threshold of registered FDs after which IOSEQ_ASYNC should be used for IO operations. -
IOUringEventLoopGroup
public IOUringEventLoopGroup(int nThreads, Executor executor, int ringsize, int iosqeAsyncThreshold) Create a new instance using the specified number of threads, the givenExecutor
, the given size of the used ringbuffer and a threshold of registered FDs after which IOSEQ_ASYNC should be used for IO operations. -
IOUringEventLoopGroup
private IOUringEventLoopGroup(int nThreads, Executor executor, io.netty.util.concurrent.EventExecutorChooserFactory chooserFactory, int ringSize, int iosqeAsyncThreshold, io.netty.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler) -
IOUringEventLoopGroup
private IOUringEventLoopGroup(int nThreads, Executor executor, io.netty.util.concurrent.EventExecutorChooserFactory chooserFactory, int ringSize, int iosqeAsyncThreshold, io.netty.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler, io.netty.channel.EventLoopTaskQueueFactory queueFactory)
-
-
Method Details
-
newChild
- Specified by:
newChild
in classio.netty.channel.MultithreadEventLoopGroup
-