Top Constructors Methods
io.netty.incubator.channel.uring

public final Class IOUringEventLoopGroup

extends MultithreadEventLoopGroup
Class Inheritance
Imports
io.netty.channel.EventLoop, .EventLoopTaskQueueFactory, .MultithreadEventLoopGroup, io.netty.util.concurrent.DefaultEventExecutorChooserFactory, .EventExecutorChooserFactory, .RejectedExecutionHandler, .RejectedExecutionHandlers, .ThreadPerTaskExecutor, io.netty.util.internal.ObjectUtil, java.util.concurrent.Executor, .ThreadFactory

Constructor Summary

AccessConstructor and Description
public
IOUringEventLoopGroup()

Create a new instance using the default number of threads and the default ThreadFactory.

public
IOUringEventLoopGroup(int nThreads)

Create a new instance using the specified number of threads and the default ThreadFactory.

public
IOUringEventLoopGroup(ThreadFactory threadFactory)

Create a new instance using the default number of threads and the given ThreadFactory.

public
IOUringEventLoopGroup(int nThreads, ThreadFactory threadFactory)

Create a new instance using the specified number of threads and the given ThreadFactory.

public
IOUringEventLoopGroup(int nThreads, Executor executor)

Create a new instance using the specified number of threads and the given Executor.

public
IOUringEventLoopGroup(int nThreads, ThreadFactory threadFactory, int ringSize, int iosqeAsyncThreshold)

Create a new instance using the specified number of threads, the given ThreadFactory, the given size of the used ringbuffer and a threshold of registered FDs after which IOSEQ_ASYNC should be used for IO operations.

public
IOUringEventLoopGroup(int nThreads, Executor executor, int ringsize, int iosqeAsyncThreshold)

Create a new instance using the specified number of threads, the given Executor, 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, EventExecutorChooserFactory chooserFactory, int ringSize, int iosqeAsyncThreshold, RejectedExecutionHandler rejectedExecutionHandler)

private
IOUringEventLoopGroup(int nThreads, Executor executor, EventExecutorChooserFactory chooserFactory, int ringSize, int iosqeAsyncThreshold, RejectedExecutionHandler rejectedExecutionHandler, EventLoopTaskQueueFactory queueFactory)

Method Summary

Modifier and TypeMethod and Description
protected EventLoop
newChild(Executor executor, Object... args)

Implements abstract io.netty.channel.MultithreadEventLoopGroup.newChild.

Create a new EventExecutor which will later then accessible via the next() method.
Inherited from io.netty.channel.MultithreadEventLoopGroup:
newDefaultThreadFactorynextregisterregisterregister

Constructor Detail

IOUringEventLoopGroupback to summary
public IOUringEventLoopGroup()

Create a new instance using the default number of threads and the default ThreadFactory.

IOUringEventLoopGroupback to summary
public IOUringEventLoopGroup(int nThreads)

Create a new instance using the specified number of threads and the default ThreadFactory.

IOUringEventLoopGroupback to summary
public IOUringEventLoopGroup(ThreadFactory threadFactory)

Create a new instance using the default number of threads and the given ThreadFactory.

IOUringEventLoopGroupback to summary
public IOUringEventLoopGroup(int nThreads, ThreadFactory threadFactory)

Create a new instance using the specified number of threads and the given ThreadFactory.

IOUringEventLoopGroupback to summary
public IOUringEventLoopGroup(int nThreads, Executor executor)

Create a new instance using the specified number of threads and the given Executor.

IOUringEventLoopGroupback to summary
public IOUringEventLoopGroup(int nThreads, ThreadFactory threadFactory, int ringSize, int iosqeAsyncThreshold)

Create a new instance using the specified number of threads, the given ThreadFactory, the given size of the used ringbuffer and a threshold of registered FDs after which IOSEQ_ASYNC should be used for IO operations.

IOUringEventLoopGroupback to summary
public IOUringEventLoopGroup(int nThreads, Executor executor, int ringsize, int iosqeAsyncThreshold)

Create a new instance using the specified number of threads, the given Executor, the given size of the used ringbuffer and a threshold of registered FDs after which IOSEQ_ASYNC should be used for IO operations.

IOUringEventLoopGroupback to summary
private IOUringEventLoopGroup(int nThreads, Executor executor, EventExecutorChooserFactory chooserFactory, int ringSize, int iosqeAsyncThreshold, RejectedExecutionHandler rejectedExecutionHandler)
IOUringEventLoopGroupback to summary
private IOUringEventLoopGroup(int nThreads, Executor executor, EventExecutorChooserFactory chooserFactory, int ringSize, int iosqeAsyncThreshold, RejectedExecutionHandler rejectedExecutionHandler, EventLoopTaskQueueFactory queueFactory)

Method Detail

newChildback to summary
protected EventLoop newChild(Executor executor, Object... args)

Implements abstract io.netty.channel.MultithreadEventLoopGroup.newChild.

Doc from io.netty.util.concurrent.MultithreadEventExecutorGroup.newChild.

Create a new EventExecutor which will later then accessible via the next() method. This method will be called for each thread that will serve this MultithreadEventExecutorGroup.

Annotations
@Override