public class SettableListenableFuture<T> extends Object implements ListenableFuture<T>
ListenableFuture
whose value can be set via set(Object)
or
setException(Throwable)
. It may also be cancelled.
Inspired by com.google.common.util.concurrent.SettableFuture
.
Constructor and Description |
---|
SettableListenableFuture() |
Modifier and Type | Method and Description |
---|---|
void |
addCallback(ListenableFutureCallback<? super T> callback)
Register the given
ListenableFutureCallback . |
void |
addCallback(SuccessCallback<? super T> successCallback,
FailureCallback failureCallback)
Java 8 lambda-friendly alternative with success and failure callbacks.
|
boolean |
cancel(boolean mayInterruptIfRunning) |
T |
get()
Retrieve the value.
|
T |
get(long timeout,
TimeUnit unit)
Retrieve the value.
|
protected void |
interruptTask()
Subclasses can override this method to implement interruption of the future's
computation.
|
boolean |
isCancelled() |
boolean |
isDone() |
boolean |
set(T value)
Set the value of this future.
|
boolean |
setException(Throwable exception)
Set the exception of this future.
|
public boolean set(T value)
true
if the
value was set successfully, or false
if the future has already been
set or cancelled.value
- the value that will be settrue
if the value was successfully set, else false
public boolean setException(Throwable exception)
true
if the
exception was set successfully, or false
if the future has already been
set or cancelled.exception
- the value that will be settrue
if the exception was successfully set, else false
public void addCallback(ListenableFutureCallback<? super T> callback)
ListenableFuture
ListenableFutureCallback
.addCallback
in interface ListenableFuture<T>
callback
- the callback to registerpublic void addCallback(SuccessCallback<? super T> successCallback, FailureCallback failureCallback)
ListenableFuture
addCallback
in interface ListenableFuture<T>
successCallback
- the success callbackfailureCallback
- the failure callbackpublic boolean cancel(boolean mayInterruptIfRunning)
public boolean isCancelled()
isCancelled
in interface Future<T>
public T get() throws InterruptedException, ExecutionException
Will return the value if it has been set via set(Object)
,
throw an ExecutionException
if it has been
set via setException(Throwable)
or throw a
CancellationException
if it has been cancelled.
get
in interface Future<T>
InterruptedException
ExecutionException
public T get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException
Will return the value if it has been set via set(Object)
,
throw an ExecutionException
if it has been
set via setException(Throwable)
or throw a
CancellationException
if it has been cancelled.
get
in interface Future<T>
timeout
- the maximum time to wait.unit
- the time unit of the timeout argument.InterruptedException
ExecutionException
TimeoutException
protected void interruptTask()
cancel(true)
.
The default implementation does nothing.