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
,java.lang.Iterable<io.netty.util.concurrent.EventExecutor>
,java.util.concurrent.Executor
,java.util.concurrent.ExecutorService
,java.util.concurrent.ScheduledExecutorService
public final class IOUringEventLoopGroup extends io.netty.channel.MultithreadEventLoopGroup
-
-
Constructor Summary
Constructors Modifier Constructor Description IOUringEventLoopGroup()
Create 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, java.util.concurrent.Executor executor)
Create a new instance using the specified number of threads and the givenExecutor
.IOUringEventLoopGroup(int nThreads, java.util.concurrent.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, java.util.concurrent.Executor executor, io.netty.util.concurrent.EventExecutorChooserFactory chooserFactory, int ringSize, int iosqeAsyncThreshold, io.netty.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler)
private
IOUringEventLoopGroup(int nThreads, java.util.concurrent.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, java.util.concurrent.ThreadFactory threadFactory)
Create a new instance using the specified number of threads and the givenThreadFactory
.IOUringEventLoopGroup(int nThreads, java.util.concurrent.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(java.util.concurrent.ThreadFactory threadFactory)
Create a new instance using the default number of threads and the givenThreadFactory
.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected io.netty.channel.EventLoop
newChild(java.util.concurrent.Executor executor, java.lang.Object... args)
-
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
-
-
-
-
Constructor Detail
-
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
public IOUringEventLoopGroup(java.util.concurrent.ThreadFactory threadFactory)
Create a new instance using the default number of threads and the givenThreadFactory
.
-
IOUringEventLoopGroup
public IOUringEventLoopGroup(int nThreads, java.util.concurrent.ThreadFactory threadFactory)
Create a new instance using the specified number of threads and the givenThreadFactory
.
-
IOUringEventLoopGroup
public IOUringEventLoopGroup(int nThreads, java.util.concurrent.Executor executor)
Create a new instance using the specified number of threads and the givenExecutor
.
-
IOUringEventLoopGroup
public IOUringEventLoopGroup(int nThreads, java.util.concurrent.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, java.util.concurrent.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, java.util.concurrent.Executor executor, io.netty.util.concurrent.EventExecutorChooserFactory chooserFactory, int ringSize, int iosqeAsyncThreshold, io.netty.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler)
-
IOUringEventLoopGroup
private IOUringEventLoopGroup(int nThreads, java.util.concurrent.Executor executor, io.netty.util.concurrent.EventExecutorChooserFactory chooserFactory, int ringSize, int iosqeAsyncThreshold, io.netty.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler, io.netty.channel.EventLoopTaskQueueFactory queueFactory)
-
-