Class ScheduledFutureTask<V>

java.lang.Object

io.netty.util.concurrent.AbstractFuture<V>

io.netty.util.concurrent.DefaultPromise<V>

io.netty.util.concurrent.PromiseTask<V>

io.netty.util.concurrent.ScheduledFutureTask<V>

All Implemented Interfaces:

Future<V>, Promise<V>, ScheduledFuture<V>, PriorityQueueNode, Comparable<Delayed>, Runnable, Delayed, Future<V>, RunnableFuture<V>, ScheduledFuture<V>

final class ScheduledFutureTask<V>
extends PromiseTask<V>
implements ScheduledFuture<V>, PriorityQueueNode

Field Summary

Fields

Modifier and Type	Field	Description
private long	deadlineNanos
private long	id
private final long	periodNanos
private int	queueIndex

Fields inherited from class DefaultPromise

PROPERTY_MAX_LISTENER_STACK_DEPTH

Fields inherited from interface PriorityQueueNode

INDEX_NOT_IN_QUEUE

Constructor Summary

Constructors

Constructor	Description
ScheduledFutureTask(AbstractScheduledEventExecutor executor, Runnable runnable, long nanoTime)
ScheduledFutureTask(AbstractScheduledEventExecutor executor, Runnable runnable, long nanoTime, long period)
ScheduledFutureTask(AbstractScheduledEventExecutor executor, Callable<V> callable, long nanoTime)
ScheduledFutureTask(AbstractScheduledEventExecutor executor, Callable<V> callable, long nanoTime, long period)

Method Summary

Modifier and Type	Method	Description
boolean	cancel(boolean mayInterruptIfRunning)	If the cancellation was successful it will fail the future with a CancellationException.
(package private) boolean	cancelWithoutRemove(boolean mayInterruptIfRunning)
int	compareTo(Delayed o)
long	deadlineNanos()
(package private) static long	deadlineToDelayNanos(long currentTimeNanos, long deadlineNanos)
long	delayNanos()
long	delayNanos(long currentTimeNanos)
protected EventExecutor	executor()	Get the executor used to notify listeners when this promise is complete.
long	getDelay(TimeUnit unit)
(package private) long	getId()
int	priorityQueueIndex(DefaultPriorityQueue<?> queue)	Get the last value set by PriorityQueueNode.priorityQueueIndex(DefaultPriorityQueue, int) for the value corresponding to queue.
void	priorityQueueIndex(DefaultPriorityQueue<?> queue, int i)	Used by DefaultPriorityQueue to maintain state for an element in the queue.
void	run()
private AbstractScheduledEventExecutor	scheduledExecutor()
(package private) void	setConsumed()
(package private) ScheduledFutureTask<V>	setId(long id)
protected StringBuilder	toStringBuilder()
private static long	validatePeriod(long period)

Methods inherited from class PromiseTask

equals, hashCode, runTask, setFailure, setFailureInternal, setSuccess, setSuccessInternal, setUncancellable, setUncancellableInternal, tryFailure, tryFailureInternal, trySuccess, trySuccessInternal

Methods inherited from class DefaultPromise

addListener, addListeners, await, await, await, awaitUninterruptibly, awaitUninterruptibly, awaitUninterruptibly, cause, checkDeadLock, get, get, getNow, isCancellable, isCancelled, isDone, isSuccess, notifyListener, notifyProgressiveListeners, removeListener, removeListeners, sync, syncUninterruptibly, toString

Methods inherited from class Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface Future

await, await, awaitUninterruptibly, awaitUninterruptibly, cause, getNow, isCancellable, isSuccess

Methods inherited from interface Future

get, get, isCancelled, isDone

Field Details

id

private long id

deadlineNanos

private long deadlineNanos

periodNanos

private final long periodNanos

queueIndex

private int queueIndex

Constructor Details

ScheduledFutureTask

ScheduledFutureTask(AbstractScheduledEventExecutor executor,
 Runnable runnable,
 long nanoTime)

ScheduledFutureTask

ScheduledFutureTask(AbstractScheduledEventExecutor executor,
 Runnable runnable,
 long nanoTime,
 long period)

ScheduledFutureTask

ScheduledFutureTask(AbstractScheduledEventExecutor executor,
 Callable<V> callable,
 long nanoTime,
 long period)

ScheduledFutureTask

ScheduledFutureTask(AbstractScheduledEventExecutor executor,
 Callable<V> callable,
 long nanoTime)

Method Details

validatePeriod

private static long validatePeriod(long period)

setId

ScheduledFutureTask<V> setId(long id)

getId

long getId()

executor

protected EventExecutor executor()

Description copied from class: DefaultPromise

Get the executor used to notify listeners when this promise is complete.

It is assumed this executor will protect against StackOverflowError exceptions. The executor may be used to avoid StackOverflowError by executing a Runnable if the stack depth exceeds a threshold.

Overrides:

executor in class DefaultPromise<V>

Returns:

The executor used to notify listeners when this promise is complete.

deadlineNanos

public long deadlineNanos()

setConsumed

void setConsumed()

delayNanos

public long delayNanos()

deadlineToDelayNanos

static long deadlineToDelayNanos(long currentTimeNanos,
 long deadlineNanos)

delayNanos

public long delayNanos(long currentTimeNanos)

getDelay

public long getDelay(TimeUnit unit)

Specified by:

getDelay in interface Delayed

compareTo

public int compareTo(Delayed o)

Specified by:

compareTo in interface Comparable<V>

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in interface RunnableFuture<V>

Overrides:

run in class PromiseTask<V>

scheduledExecutor

private AbstractScheduledEventExecutor scheduledExecutor()

cancel

public boolean cancel(boolean mayInterruptIfRunning)

If the cancellation was successful it will fail the future with a CancellationException.

Specified by:

cancel in interface Future<V>

Specified by:

cancel in interface Future<V>

Overrides:

cancel in class PromiseTask<V>

Parameters:

mayInterruptIfRunning - this value has no effect in this implementation.

cancelWithoutRemove

boolean cancelWithoutRemove(boolean mayInterruptIfRunning)

toStringBuilder

protected StringBuilder toStringBuilder()

Overrides:

toStringBuilder in class PromiseTask<V>

priorityQueueIndex

public int priorityQueueIndex(DefaultPriorityQueue<?> queue)

Description copied from interface: PriorityQueueNode

Get the last value set by PriorityQueueNode.priorityQueueIndex(DefaultPriorityQueue, int) for the value corresponding to queue.

Throwing exceptions from this method will result in undefined behavior.

Specified by:

priorityQueueIndex in interface PriorityQueueNode

priorityQueueIndex

public void priorityQueueIndex(DefaultPriorityQueue<?> queue,
 int i)

Description copied from interface: PriorityQueueNode

Used by DefaultPriorityQueue to maintain state for an element in the queue.

Throwing exceptions from this method will result in undefined behavior.

Specified by:

priorityQueueIndex in interface PriorityQueueNode

Parameters:

queue - The queue for which the index is being set.

i - The index as used by DefaultPriorityQueue.