Package io.netty.util

Class HashedWheelTimer.Worker

java.lang.Object
io.netty.util.HashedWheelTimer.Worker
All Implemented Interfaces:
Runnable
Enclosing class:
HashedWheelTimer

private final class HashedWheelTimer.Worker extends Object implements Runnable
  • Field Details

    • unprocessedTimeouts

      private final Set<Timeout> unprocessedTimeouts
    • tick

      private long tick
  • Constructor Details

    • Worker

      private Worker()
  • Method Details

    • run

      public void run()
      Specified by:
      run in interface Runnable
    • transferTimeoutsToBuckets

      private void transferTimeoutsToBuckets()
    • processCancelledTasks

      private void processCancelledTasks()
    • waitForNextTick

      private long waitForNextTick()
      calculate goal nanoTime from startTime and current tick number, then wait until that goal has been reached.
      Returns:
      Long.MIN_VALUE if received a shutdown request, current time otherwise (with Long.MIN_VALUE changed by +1)
    • unprocessedTimeouts

      public Set<Timeout> unprocessedTimeouts()