Class 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 default ThreadFactory.
        IOUringEventLoopGroup​(int nThreads)
      Create a new instance using the specified number of threads and the default ThreadFactory.
        IOUringEventLoopGroup​(int nThreads, java.util.concurrent.Executor executor)
      Create a new instance using the specified number of threads and the given Executor.
        IOUringEventLoopGroup​(int nThreads, java.util.concurrent.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, 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 given ThreadFactory.
        IOUringEventLoopGroup​(int nThreads, java.util.concurrent.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​(java.util.concurrent.ThreadFactory threadFactory)
      Create a new instance using the default number of threads and the given ThreadFactory.
    • 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
      • 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 Detail

      • 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​(java.util.concurrent.ThreadFactory threadFactory)
        Create a new instance using the default number of threads and the given ThreadFactory.
      • IOUringEventLoopGroup

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

        public IOUringEventLoopGroup​(int nThreads,
                                     java.util.concurrent.Executor executor)
        Create a new instance using the specified number of threads and the given Executor.
      • 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 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,
                                     java.util.concurrent.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,
                                      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)
    • Method Detail

      • newChild

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