Class DefaultPromise<V>
- java.lang.Object
-
- io.netty.util.concurrent.AbstractFuture<V>
-
- io.netty.util.concurrent.DefaultPromise<V>
-
- Direct Known Subclasses:
DefaultChannelPromise
,DefaultProgressivePromise
public class DefaultPromise<V> extends AbstractFuture<V> implements Promise<V>
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
PROPERTY_MAX_LISTENER_STACK_DEPTH
System property with integer type value, that determine the max reentrancy/recursion level for when listener notifications prompt other listeners to be notified.
-
Constructor Summary
Constructors Modifier Constructor Description protected
DefaultPromise()
Seeexecutor()
for expectations of the executor.DefaultPromise(EventExecutor executor)
Creates a new instance.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description Promise<V>
addListener(GenericFutureListener<? extends Future<? super V>> listener)
Adds the specified listener to this future.Promise<V>
addListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Adds the specified listeners to this future.Promise<V>
await()
Waits for this future to be completed.boolean
await(long timeoutMillis)
Waits for this future to be completed within the specified time limit.boolean
await(long timeout, java.util.concurrent.TimeUnit unit)
Waits for this future to be completed within the specified time limit.Promise<V>
awaitUninterruptibly()
Waits for this future to be completed without interruption.boolean
awaitUninterruptibly(long timeoutMillis)
Waits for this future to be completed within the specified time limit without interruption.boolean
awaitUninterruptibly(long timeout, java.util.concurrent.TimeUnit unit)
Waits for this future to be completed within the specified time limit without interruption.boolean
cancel(boolean mayInterruptIfRunning)
If the cancellation was successful it will fail the future with aCancellationException
.java.lang.Throwable
cause()
Returns the cause of the failed I/O operation if the I/O operation has failed.protected void
checkDeadLock()
protected EventExecutor
executor()
Get the executor used to notify listeners when this promise is complete.V
get()
V
get(long timeout, java.util.concurrent.TimeUnit unit)
V
getNow()
Return the result without blocking.boolean
isCancellable()
returnstrue
if and only if the operation can be cancelled viaFuture.cancel(boolean)
.boolean
isCancelled()
boolean
isDone()
boolean
isSuccess()
Returnstrue
if and only if the I/O operation was completed successfully.protected static void
notifyListener(EventExecutor eventExecutor, Future<?> future, GenericFutureListener<?> listener)
Notify a listener that a future has completed.Promise<V>
removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Removes the first occurrence of the specified listener from this future.Promise<V>
removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Removes the first occurrence for each of the listeners from this future.Promise<V>
setFailure(java.lang.Throwable cause)
Marks this future as a failure and notifies all listeners.Promise<V>
setSuccess(V result)
Marks this future as a success and notifies all listeners.boolean
setUncancellable()
Make this future impossible to cancel.Promise<V>
sync()
Waits for this future until it is done, and rethrows the cause of the failure if this future failed.Promise<V>
syncUninterruptibly()
Waits for this future until it is done, and rethrows the cause of the failure if this future failed.java.lang.String
toString()
protected java.lang.StringBuilder
toStringBuilder()
boolean
tryFailure(java.lang.Throwable cause)
Marks this future as a failure and notifies all listeners.boolean
trySuccess(V result)
Marks this future as a success and notifies all listeners.
-
-
-
Field Detail
-
PROPERTY_MAX_LISTENER_STACK_DEPTH
public static final java.lang.String PROPERTY_MAX_LISTENER_STACK_DEPTH
System property with integer type value, that determine the max reentrancy/recursion level for when listener notifications prompt other listeners to be notified.When the reentrancy/recursion level becomes greater than this number, a new task will instead be scheduled on the event loop, to finish notifying any subsequent listners.
The default value is
8
.- See Also:
- Constant Field Values
-
-
Constructor Detail
-
DefaultPromise
public DefaultPromise(EventExecutor executor)
Creates a new instance.It is preferable to use
EventExecutor.newPromise()
to create a new promise- Parameters:
executor
- theEventExecutor
which is used to notify the promise once it is complete. It is assumed this executor will protect againstStackOverflowError
exceptions. The executor may be used to avoidStackOverflowError
by executing aRunnable
if the stack depth exceeds a threshold.
-
DefaultPromise
protected DefaultPromise()
Seeexecutor()
for expectations of the executor.
-
-
Method Detail
-
setSuccess
public Promise<V> setSuccess(V result)
Description copied from interface:Promise
Marks this future as a success and notifies all listeners. If it is success or failed already it will throw anIllegalStateException
.- Specified by:
setSuccess
in interfacePromise<V>
-
trySuccess
public boolean trySuccess(V result)
Description copied from interface:Promise
Marks this future as a success and notifies all listeners.- Specified by:
trySuccess
in interfacePromise<V>
- Returns:
true
if and only if successfully marked this future as a success. Otherwisefalse
because this future is already marked as either a success or a failure.
-
setFailure
public Promise<V> setFailure(java.lang.Throwable cause)
Description copied from interface:Promise
Marks this future as a failure and notifies all listeners. If it is success or failed already it will throw anIllegalStateException
.- Specified by:
setFailure
in interfacePromise<V>
-
tryFailure
public boolean tryFailure(java.lang.Throwable cause)
Description copied from interface:Promise
Marks this future as a failure and notifies all listeners.- Specified by:
tryFailure
in interfacePromise<V>
- Returns:
true
if and only if successfully marked this future as a failure. Otherwisefalse
because this future is already marked as either a success or a failure.
-
setUncancellable
public boolean setUncancellable()
Description copied from interface:Promise
Make this future impossible to cancel.- Specified by:
setUncancellable
in interfacePromise<V>
- Returns:
true
if and only if successfully marked this future as uncancellable or it is already done without being cancelled.false
if this future has been cancelled already.
-
isSuccess
public boolean isSuccess()
Description copied from interface:Future
Returnstrue
if and only if the I/O operation was completed successfully.
-
isCancellable
public boolean isCancellable()
Description copied from interface:Future
returnstrue
if and only if the operation can be cancelled viaFuture.cancel(boolean)
.- Specified by:
isCancellable
in interfaceFuture<V>
-
cause
public java.lang.Throwable cause()
Description copied from interface:Future
Returns the cause of the failed I/O operation if the I/O operation has failed.
-
addListener
public Promise<V> addListener(GenericFutureListener<? extends Future<? super V>> listener)
Description copied from interface:Future
Adds the specified listener to this future. The specified listener is notified when this future is done. If this future is already completed, the specified listener is notified immediately.- Specified by:
addListener
in interfaceFuture<V>
- Specified by:
addListener
in interfacePromise<V>
-
addListeners
public Promise<V> addListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Description copied from interface:Future
Adds the specified listeners to this future. The specified listeners are notified when this future is done. If this future is already completed, the specified listeners are notified immediately.- Specified by:
addListeners
in interfaceFuture<V>
- Specified by:
addListeners
in interfacePromise<V>
-
removeListener
public Promise<V> removeListener(GenericFutureListener<? extends Future<? super V>> listener)
Description copied from interface:Future
Removes the first occurrence of the specified listener from this future. The specified listener is no longer notified when this future is done. If the specified listener is not associated with this future, this method does nothing and returns silently.- Specified by:
removeListener
in interfaceFuture<V>
- Specified by:
removeListener
in interfacePromise<V>
-
removeListeners
public Promise<V> removeListeners(GenericFutureListener<? extends Future<? super V>>... listeners)
Description copied from interface:Future
Removes the first occurrence for each of the listeners from this future. The specified listeners are no longer notified when this future is done. If the specified listeners are not associated with this future, this method does nothing and returns silently.- Specified by:
removeListeners
in interfaceFuture<V>
- Specified by:
removeListeners
in interfacePromise<V>
-
await
public Promise<V> await() throws java.lang.InterruptedException
Description copied from interface:Future
Waits for this future to be completed.
-
awaitUninterruptibly
public Promise<V> awaitUninterruptibly()
Description copied from interface:Future
Waits for this future to be completed without interruption. This method catches anInterruptedException
and discards it silently.- Specified by:
awaitUninterruptibly
in interfaceFuture<V>
- Specified by:
awaitUninterruptibly
in interfacePromise<V>
-
await
public boolean await(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
Description copied from interface:Future
Waits for this future to be completed within the specified time limit.
-
await
public boolean await(long timeoutMillis) throws java.lang.InterruptedException
Description copied from interface:Future
Waits for this future to be completed within the specified time limit.
-
awaitUninterruptibly
public boolean awaitUninterruptibly(long timeout, java.util.concurrent.TimeUnit unit)
Description copied from interface:Future
Waits for this future to be completed within the specified time limit without interruption. This method catches anInterruptedException
and discards it silently.- Specified by:
awaitUninterruptibly
in interfaceFuture<V>
- Returns:
true
if and only if the future was completed within the specified time limit
-
awaitUninterruptibly
public boolean awaitUninterruptibly(long timeoutMillis)
Description copied from interface:Future
Waits for this future to be completed within the specified time limit without interruption. This method catches anInterruptedException
and discards it silently.- Specified by:
awaitUninterruptibly
in interfaceFuture<V>
- Returns:
true
if and only if the future was completed within the specified time limit
-
getNow
public V getNow()
Description copied from interface:Future
Return the result without blocking. If the future is not done yet this will returnnull
.As it is possible that a
null
value is used to mark the future as successful you also need to check if the future is really done withFuture.isDone()
and not rely on the returnednull
value.
-
get
public V get() throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
- Specified by:
get
in interfacejava.util.concurrent.Future<V>
- Overrides:
get
in classAbstractFuture<V>
- Throws:
java.lang.InterruptedException
java.util.concurrent.ExecutionException
-
get
public V get(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException, java.util.concurrent.TimeoutException
- Specified by:
get
in interfacejava.util.concurrent.Future<V>
- Overrides:
get
in classAbstractFuture<V>
- Throws:
java.lang.InterruptedException
java.util.concurrent.ExecutionException
java.util.concurrent.TimeoutException
-
cancel
public boolean cancel(boolean mayInterruptIfRunning)
If the cancellation was successful it will fail the future with aCancellationException
.
-
isCancelled
public boolean isCancelled()
- Specified by:
isCancelled
in interfacejava.util.concurrent.Future<V>
-
isDone
public boolean isDone()
- Specified by:
isDone
in interfacejava.util.concurrent.Future<V>
-
sync
public Promise<V> sync() throws java.lang.InterruptedException
Description copied from interface:Future
Waits for this future until it is done, and rethrows the cause of the failure if this future failed.
-
syncUninterruptibly
public Promise<V> syncUninterruptibly()
Description copied from interface:Future
Waits for this future until it is done, and rethrows the cause of the failure if this future failed.- Specified by:
syncUninterruptibly
in interfaceFuture<V>
- Specified by:
syncUninterruptibly
in interfacePromise<V>
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
toStringBuilder
protected java.lang.StringBuilder toStringBuilder()
-
executor
protected EventExecutor executor()
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 avoidStackOverflowError
by executing aRunnable
if the stack depth exceeds a threshold.- Returns:
- The executor used to notify listeners when this promise is complete.
-
checkDeadLock
protected void checkDeadLock()
-
notifyListener
protected static void notifyListener(EventExecutor eventExecutor, Future<?> future, GenericFutureListener<?> listener)
Notify a listener that a future has completed.This method has a fixed depth of
MAX_LISTENER_STACK_DEPTH
that will limit recursion to preventStackOverflowError
and will stop notifying listeners added after this threshold is exceeded.- Parameters:
eventExecutor
- the executor to use to notify the listenerlistener
.future
- the future that is complete.listener
- the listener to notify.
-
-