Package io.netty.incubator.channel.uring

Class IOUringEventLoop

java.lang.Object
java.util.concurrent.AbstractExecutorService
io.netty.util.concurrent.AbstractEventExecutor
io.netty.util.concurrent.AbstractScheduledEventExecutor
io.netty.util.concurrent.SingleThreadEventExecutor
io.netty.channel.SingleThreadEventLoop
io.netty.incubator.channel.uring.IOUringEventLoop
All Implemented Interfaces:
io.netty.channel.EventLoop, io.netty.channel.EventLoopGroup, io.netty.util.concurrent.EventExecutor, io.netty.util.concurrent.EventExecutorGroup, io.netty.util.concurrent.OrderedEventExecutor, Iterable<io.netty.util.concurrent.EventExecutor>, Executor, ExecutorService, ScheduledExecutorService
public final class IOUringEventLoop extends io.netty.channel.SingleThreadEventLoop
An EventLoop that uses IO_URING.

  • Nested Class Summary

    Nested classes/interfaces inherited from class io.netty.channel.SingleThreadEventLoop

    io.netty.channel.SingleThreadEventLoop.ChannelsReadOnlyIterator<T extends io.netty.channel.Channel>

    Nested classes/interfaces inherited from class io.netty.util.concurrent.SingleThreadEventExecutor

    io.netty.util.concurrent.SingleThreadEventExecutor.NonWakeupRunnable

    Nested classes/interfaces inherited from class io.netty.util.concurrent.AbstractEventExecutor

    io.netty.util.concurrent.AbstractEventExecutor.LazyRunnable

  • Field Summary

    Fields inherited from class io.netty.channel.SingleThreadEventLoop

    DEFAULT_MAX_PENDING_TASKS

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    cleanup()
     
    protected Queue<Runnable>
    newTaskQueue(int maxPendingTasks)
     
    protected void
    run()
     
    void
    submitIO()
    Submit the IO so the kernel can process it.
    protected void
    wakeup(boolean inEventLoop)
     

    Methods inherited from class io.netty.channel.SingleThreadEventLoop

    afterRunningAllTasks, executeAfterEventLoopIteration, hasTasks, next, parent, pendingTasks, register, register, register, registeredChannels, registeredChannelsIterator

    Methods inherited from class io.netty.util.concurrent.SingleThreadEventExecutor

    addShutdownHook, addTask, awaitTermination, confirmShutdown, deadlineNanos, delayNanos, execute, inEventLoop, interruptThread, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isShuttingDown, isTerminated, lazyExecute, newTaskQueue, peekTask, pollTask, pollTaskFrom, reject, reject, removeShutdownHook, removeTask, runAllTasks, runAllTasks, runAllTasksFrom, runScheduledAndExecutorTasks, shutdown, shutdownGracefully, takeTask, terminationFuture, threadProperties, updateLastExecutionTime, wakesUpForTask

    Methods inherited from class io.netty.util.concurrent.AbstractScheduledEventExecutor

    afterScheduledTaskSubmitted, beforeScheduledTaskSubmitted, cancelScheduledTasks, deadlineToDelayNanos, getCurrentTimeNanos, hasScheduledTasks, initialNanoTime, nanoTime, nextScheduledTaskDeadlineNanos, nextScheduledTaskNano, pollScheduledTask, pollScheduledTask, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, validateScheduled

    Methods inherited from class io.netty.util.concurrent.AbstractEventExecutor

    inEventLoop, iterator, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, newTaskFor, newTaskFor, runTask, safeExecute, 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.EventExecutor

    inEventLoop, inEventLoop, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture

    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

  • Method Details

    • submitIO

      public void submitIO()
      Submit the IO so the kernel can process it. This method can be called to "force" the submission (before it is submitted by netty itself).

    • newTaskQueue

      protected Queue<Runnable> newTaskQueue(int maxPendingTasks)
      Overrides:
      newTaskQueue in class io.netty.util.concurrent.SingleThreadEventExecutor

    • run

      protected void run()
      Specified by:
      run in class io.netty.util.concurrent.SingleThreadEventExecutor

    • cleanup

      protected void cleanup()
      Overrides:
      cleanup in class io.netty.util.concurrent.SingleThreadEventExecutor

    • wakeup

      protected void wakeup(boolean inEventLoop)
      Overrides:
      wakeup in class io.netty.util.concurrent.SingleThreadEventExecutor