final class ScheduledFutureTask<V> extends PromiseTask<V> implements ScheduledFuture<V>
| Modifier and Type | Field and Description |
|---|---|
private long |
deadlineNanos |
private long |
id |
private static java.util.concurrent.atomic.AtomicLong |
nextTaskId |
private long |
periodNanos |
private static long |
START_TIME |
task| Constructor and Description |
|---|
ScheduledFutureTask(AbstractScheduledEventExecutor executor,
java.util.concurrent.Callable<V> callable,
long nanoTime) |
ScheduledFutureTask(AbstractScheduledEventExecutor executor,
java.util.concurrent.Callable<V> callable,
long nanoTime,
long period) |
ScheduledFutureTask(AbstractScheduledEventExecutor executor,
java.lang.Runnable runnable,
V result,
long nanoTime) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
cancel(boolean mayInterruptIfRunning)
If the cancellation was successful it will fail the future with an
CancellationException. |
(package private) boolean |
cancelWithoutRemove(boolean mayInterruptIfRunning) |
int |
compareTo(java.util.concurrent.Delayed o) |
long |
deadlineNanos() |
(package private) static long |
deadlineNanos(long delay) |
long |
delayNanos() |
long |
delayNanos(long currentTimeNanos) |
protected EventExecutor |
executor()
Get the executor used to notify listeners when this promise is complete.
|
long |
getDelay(java.util.concurrent.TimeUnit unit) |
(package private) static long |
nanoTime() |
void |
run() |
protected java.lang.StringBuilder |
toStringBuilder() |
equals, hashCode, setFailure, setFailureInternal, setSuccess, setSuccessInternal, setUncancellable, setUncancellableInternal, toCallable, tryFailure, tryFailureInternal, trySuccess, trySuccessInternaladdListener, addListeners, await, await, await, awaitUninterruptibly, awaitUninterruptibly, awaitUninterruptibly, cause, checkDeadLock, getNow, isCancellable, isCancelled, isDone, isSuccess, notifyListener, notifyProgressiveListeners, removeListener, removeListeners, sync, syncUninterruptibly, toStringget, getclone, finalize, getClass, notify, notifyAll, wait, wait, waitaddListener, addListeners, await, await, await, awaitUninterruptibly, awaitUninterruptibly, awaitUninterruptibly, cause, getNow, isCancellable, isSuccess, removeListener, removeListeners, sync, syncUninterruptiblyprivate static final java.util.concurrent.atomic.AtomicLong nextTaskId
private static final long START_TIME
private final long id
private long deadlineNanos
private final long periodNanos
ScheduledFutureTask(AbstractScheduledEventExecutor executor, java.lang.Runnable runnable, V result, long nanoTime)
ScheduledFutureTask(AbstractScheduledEventExecutor executor, java.util.concurrent.Callable<V> callable, long nanoTime, long period)
ScheduledFutureTask(AbstractScheduledEventExecutor executor, java.util.concurrent.Callable<V> callable, long nanoTime)
static long nanoTime()
static long deadlineNanos(long delay)
protected EventExecutor executor()
DefaultPromise
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.
executor in class DefaultPromise<V>public long deadlineNanos()
public long delayNanos()
public long delayNanos(long currentTimeNanos)
public long getDelay(java.util.concurrent.TimeUnit unit)
getDelay in interface java.util.concurrent.Delayedpublic int compareTo(java.util.concurrent.Delayed o)
compareTo in interface java.lang.Comparable<java.util.concurrent.Delayed>public void run()
run in interface java.lang.Runnablerun in interface java.util.concurrent.RunnableFuture<V>run in class PromiseTask<V>public boolean cancel(boolean mayInterruptIfRunning)
FutureCancellationException.cancel in interface java.util.concurrent.Future<V>cancel in class DefaultPromise<V>boolean cancelWithoutRemove(boolean mayInterruptIfRunning)
protected java.lang.StringBuilder toStringBuilder()
toStringBuilder in class PromiseTask<V>