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, trySuccessInternal
addListener, addListeners, await, await, await, awaitUninterruptibly, awaitUninterruptibly, awaitUninterruptibly, cause, checkDeadLock, getNow, isCancellable, isCancelled, isDone, isSuccess, notifyListener, notifyProgressiveListeners, removeListener, removeListeners, sync, syncUninterruptibly, toString
get, get
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
addListener, addListeners, await, await, await, awaitUninterruptibly, awaitUninterruptibly, awaitUninterruptibly, cause, getNow, isCancellable, isSuccess, removeListener, removeListeners, sync, syncUninterruptibly
private 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.Delayed
public 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.Runnable
run
in interface java.util.concurrent.RunnableFuture<V>
run
in class PromiseTask<V>
public boolean cancel(boolean mayInterruptIfRunning)
Future
CancellationException
.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>