All Implemented Interfaces:

EventExecutor, EventExecutorGroup, java.lang.Iterable<EventExecutor>, java.util.concurrent.Executor, java.util.concurrent.ExecutorService, java.util.concurrent.ScheduledExecutorService

Direct Known Subclasses:

GlobalEventExecutor, SingleThreadEventExecutor

public abstract class AbstractScheduledEventExecutor
extends AbstractEventExecutor 

• Constructor Summary

  Constructors

  Constructor and Description
  AbstractScheduledEventExecutor ()

• Method Summary

  All Methods

  Modifier and Type	Method and Description
  protected void	cancelScheduledTasks () Cancel all scheduled tasks.
  protected boolean	hasScheduledTasks () Returns true if a scheduled task is ready for processing.
  protected static long	nanoTime ()
  protected long	nextScheduledTaskNano () Return the nanoseconds when the next scheduled task is ready to be run or -1 if no task is scheduled.
  protected java.lang.Runnable	pollScheduledTask ()
  protected java.lang.Runnable	pollScheduledTask (long nanoTime) Return the Runnable which is ready to be executed with the given nanoTime.
  <V> ScheduledFuture<V>	schedule (java.util.concurrent.Callable<V> callable, long delay, java.util.concurrent.TimeUnit unit)
  ScheduledFuture<?>	schedule (java.lang.Runnable command, long delay, java.util.concurrent.TimeUnit unit)
  ScheduledFuture<?>	scheduleAtFixedRate (java.lang.Runnable command, long initialDelay, long period, java.util.concurrent.TimeUnit unit)
  ScheduledFuture<?>	scheduleWithFixedDelay (java.lang.Runnable command, long initialDelay, long delay, java.util.concurrent.TimeUnit unit)

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

    inEventLoop, iterator, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, newTaskFor, newTaskFor, next, shutdown, shutdownGracefully, shutdownNow, submit, submit, submit

  • Methods inherited from class java.util.concurrent.AbstractExecutorService

    invokeAll, invokeAll, invokeAny, invokeAny

  • 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, parent

  • Methods inherited from interface io.netty.util.concurrent.EventExecutorGroup

    isShuttingDown, shutdownGracefully, terminationFuture

  • Methods inherited from interface java.util.concurrent.ExecutorService

    awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated

  • Methods inherited from interface java.util.concurrent.Executor

    execute

  • Methods inherited from interface java.lang.Iterable

    forEach, spliterator

• Constructor Detail

  • AbstractScheduledEventExecutor

    public AbstractScheduledEventExecutor()

• Method Detail

  • nanoTime

    protected static long nanoTime()

  • cancelScheduledTasks

    protected void cancelScheduledTasks()

    Cancel all scheduled tasks. This method MUST be called only when AbstractEventExecutor.inEventLoop() is true.

  • pollScheduledTask

    protected final java.lang.Runnable pollScheduledTask()

    See Also:

    pollScheduledTask(long)

  • pollScheduledTask

    protected final java.lang.Runnable pollScheduledTask(long nanoTime)

    Return the Runnable which is ready to be executed with the given nanoTime. You should use nanoTime() to retrieve the the correct nanoTime.

  • nextScheduledTaskNano

    protected final long nextScheduledTaskNano()

    Return the nanoseconds when the next scheduled task is ready to be run or -1 if no task is scheduled.

  • hasScheduledTasks

    protected final boolean hasScheduledTasks()

    Returns true if a scheduled task is ready for processing.

  • schedule

    public ScheduledFuture<?> schedule(java.lang.Runnable command,
     long delay,
     java.util.concurrent.TimeUnit unit)

    Specified by:

    schedule in interface EventExecutorGroup

    Specified by:

    schedule in interface java.util.concurrent.ScheduledExecutorService

    Overrides:

    schedule in class AbstractEventExecutor

  • schedule

    public <V> ScheduledFuture<V> schedule(java.util.concurrent.Callable<V> callable,
     long delay,
     java.util.concurrent.TimeUnit unit)

    Specified by:

    schedule in interface EventExecutorGroup

    Specified by:

    schedule in interface java.util.concurrent.ScheduledExecutorService

    Overrides:

    schedule in class AbstractEventExecutor

  • scheduleAtFixedRate

    public ScheduledFuture<?> scheduleAtFixedRate(java.lang.Runnable command,
     long initialDelay,
     long period,
     java.util.concurrent.TimeUnit unit)

    Specified by:

    scheduleAtFixedRate in interface EventExecutorGroup

    Specified by:

    scheduleAtFixedRate in interface java.util.concurrent.ScheduledExecutorService

    Overrides:

    scheduleAtFixedRate in class AbstractEventExecutor

  • scheduleWithFixedDelay

    public ScheduledFuture<?> scheduleWithFixedDelay(java.lang.Runnable command,
     long initialDelay,
     long delay,
     java.util.concurrent.TimeUnit unit)

    Specified by:

    scheduleWithFixedDelay in interface EventExecutorGroup

    Specified by:

    scheduleWithFixedDelay in interface java.util.concurrent.ScheduledExecutorService

    Overrides:

    scheduleWithFixedDelay in class AbstractEventExecutor