Package io.netty.util.concurrent
Class UnorderedThreadPoolEventExecutor.RunnableScheduledFutureTask<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.UnorderedThreadPoolEventExecutor.RunnableScheduledFutureTask<V>
-
- All Implemented Interfaces:
Future<V>
,Promise<V>
,ScheduledFuture<V>
,java.lang.Comparable<java.util.concurrent.Delayed>
,java.lang.Runnable
,java.util.concurrent.Delayed
,java.util.concurrent.Future<V>
,java.util.concurrent.RunnableFuture<V>
,java.util.concurrent.RunnableScheduledFuture<V>
,java.util.concurrent.ScheduledFuture<V>
- Enclosing class:
- UnorderedThreadPoolEventExecutor
private static final class UnorderedThreadPoolEventExecutor.RunnableScheduledFutureTask<V> extends PromiseTask<V> implements java.util.concurrent.RunnableScheduledFuture<V>, ScheduledFuture<V>
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.concurrent.RunnableScheduledFuture<V>
future
private boolean
wasCallable
-
Fields inherited from class io.netty.util.concurrent.DefaultPromise
PROPERTY_MAX_LISTENER_STACK_DEPTH
-
-
Constructor Summary
Constructors Constructor Description RunnableScheduledFutureTask(EventExecutor executor, java.util.concurrent.RunnableScheduledFuture<V> future, boolean wasCallable)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
compareTo(java.util.concurrent.Delayed o)
long
getDelay(java.util.concurrent.TimeUnit unit)
boolean
isPeriodic()
void
run()
(package private) V
runTask()
-
Methods inherited from class io.netty.util.concurrent.PromiseTask
cancel, equals, hashCode, setFailure, setFailureInternal, setSuccess, setSuccessInternal, setUncancellable, setUncancellableInternal, toStringBuilder, tryFailure, tryFailureInternal, trySuccess, trySuccessInternal
-
Methods inherited from class io.netty.util.concurrent.DefaultPromise
addListener, addListeners, await, await, await, awaitUninterruptibly, awaitUninterruptibly, awaitUninterruptibly, cause, checkDeadLock, executor, get, get, getNow, isCancellable, isCancelled, isDone, isSuccess, notifyListener, notifyProgressiveListeners, removeListener, removeListeners, sync, syncUninterruptibly, toString
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface io.netty.util.concurrent.Future
await, await, awaitUninterruptibly, awaitUninterruptibly, cancel, cause, getNow, isCancellable, isSuccess
-
-
-
-
Field Detail
-
future
private final java.util.concurrent.RunnableScheduledFuture<V> future
-
wasCallable
private final boolean wasCallable
-
-
Constructor Detail
-
RunnableScheduledFutureTask
RunnableScheduledFutureTask(EventExecutor executor, java.util.concurrent.RunnableScheduledFuture<V> future, boolean wasCallable)
-
-
Method Detail
-
runTask
V runTask() throws java.lang.Throwable
- Overrides:
runTask
in classPromiseTask<V>
- Throws:
java.lang.Throwable
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
- Specified by:
run
in interfacejava.util.concurrent.RunnableFuture<V>
- Overrides:
run
in classPromiseTask<V>
-
isPeriodic
public boolean isPeriodic()
- Specified by:
isPeriodic
in interfacejava.util.concurrent.RunnableScheduledFuture<V>
-
getDelay
public long getDelay(java.util.concurrent.TimeUnit unit)
- Specified by:
getDelay
in interfacejava.util.concurrent.Delayed
-
compareTo
public int compareTo(java.util.concurrent.Delayed o)
- Specified by:
compareTo
in interfacejava.lang.Comparable<V>
-
-