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

    Constructors
    Modifier
    Constructor
    Description
     
    Create a new instance using the default number of threads and the default ThreadFactory.
     
    IOUringEventLoopGroup(int nThreads)
    Create a new instance using the specified number of threads and the default ThreadFactory.
     
    IOUringEventLoopGroup(int nThreads, Executor executor)
    Create a new instance using the specified number of threads and the given Executor.
     
    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, 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 given ThreadFactory.
     
    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.
     
    Create a new instance using the default number of threads and the given ThreadFactory.
  • Method Summary

    Modifier and Type
    Method
    Description
    protected io.netty.channel.EventLoop
    newChild(Executor executor, 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, ticker

    Methods inherited from interface java.util.concurrent.Executor

    execute

    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 default ThreadFactory.
    • IOUringEventLoopGroup

      public IOUringEventLoopGroup(int nThreads)
      Create a new instance using the specified number of threads and the default ThreadFactory.
    • IOUringEventLoopGroup

      public IOUringEventLoopGroup(ThreadFactory threadFactory)
      Create a new instance using the default number of threads and the given ThreadFactory.
    • IOUringEventLoopGroup

      public IOUringEventLoopGroup(int nThreads, ThreadFactory threadFactory)
      Create a new instance using the specified number of threads and the given ThreadFactory.
    • IOUringEventLoopGroup

      public IOUringEventLoopGroup(int nThreads, Executor executor)
      Create a new instance using the specified number of threads and the given Executor.
    • IOUringEventLoopGroup

      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.
    • IOUringEventLoopGroup

      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.
    • 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

      protected io.netty.channel.EventLoop newChild(Executor executor, Object... args)
      Specified by:
      newChild in class io.netty.channel.MultithreadEventLoopGroup