io.netty.util.concurrent

Class AbstractScheduledEventExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

io.netty.util.concurrent.AbstractEventExecutor

io.netty.util.concurrent.AbstractScheduledEventExecutor

All Implemented Interfaces:

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

Direct Known Subclasses:

EmbeddedEventLoop, GlobalEventExecutor, SingleThreadEventExecutor

public abstract class AbstractScheduledEventExecutor
extends AbstractEventExecutor

Abstract base class for EventExecutors that want to support scheduling.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) java.util.Queue<ScheduledFutureTask<?>>	scheduledTaskQueue

Constructor Summary

Constructors

Constructor and Description
AbstractScheduledEventExecutor()

Method Summary

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.
private static boolean	isNullOrEmpty(java.util.Queue<ScheduledFutureTask<?>> queue)
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.
(package private) ScheduledFutureTask<?>	peekScheduledTask()
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.
(package private) void	removeScheduled(ScheduledFutureTask<?> task)
<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)
(package private) <V> ScheduledFuture<V>	schedule(ScheduledFutureTask<V> task)
ScheduledFuture<?>	scheduleAtFixedRate(java.lang.Runnable command, long initialDelay, long period, java.util.concurrent.TimeUnit unit)
(package private) java.util.Queue<ScheduledFutureTask<?>>	scheduledTaskQueue()
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

Field Detail

scheduledTaskQueue

java.util.Queue<ScheduledFutureTask<?>> scheduledTaskQueue

Constructor Detail

AbstractScheduledEventExecutor

public AbstractScheduledEventExecutor()

Method Detail

nanoTime

protected static long nanoTime()

scheduledTaskQueue

java.util.Queue<ScheduledFutureTask<?>> scheduledTaskQueue()

isNullOrEmpty

private static boolean isNullOrEmpty(java.util.Queue<ScheduledFutureTask<?>> queue)

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.

peekScheduledTask

final ScheduledFutureTask<?> peekScheduledTask()

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

schedule

<V> ScheduledFuture<V> schedule(ScheduledFutureTask<V> task)

removeScheduled

final void removeScheduled(ScheduledFutureTask<?> task)