Callback.Completable, Callback.Completing, Callback.InvocableCallback, Callback.Nested
Invocable.InvocationType
Modifier and Type | Field and Description |
---|---|
private java.lang.Throwable |
_cause |
private java.util.concurrent.atomic.AtomicBoolean |
_done |
private java.util.concurrent.CountDownLatch |
_latch |
private static java.lang.Throwable |
COMPLETED |
static FutureCallback |
SUCCEEDED |
__nonBlocking
Constructor and Description |
---|
FutureCallback() |
FutureCallback(boolean completed) |
FutureCallback(java.lang.Throwable failed) |
Modifier and Type | Method and Description |
---|---|
boolean |
cancel(boolean mayInterruptIfRunning) |
void |
failed(java.lang.Throwable cause)
Callback invoked when the operation fails.
|
java.lang.Void |
get() |
java.lang.Void |
get(long timeout,
java.util.concurrent.TimeUnit unit) |
boolean |
isCancelled() |
boolean |
isDone() |
static void |
rethrow(java.util.concurrent.ExecutionException e) |
void |
succeeded()
Callback invoked when the operation completes.
|
java.lang.String |
toString() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
combine, from, from, from, from, from, from
combine, getInvocationType, getInvocationType, invokeNonBlocking, isNonBlockingInvocation
private static final java.lang.Throwable COMPLETED
public static final FutureCallback SUCCEEDED
private final java.util.concurrent.atomic.AtomicBoolean _done
private final java.util.concurrent.CountDownLatch _latch
private java.lang.Throwable _cause
public FutureCallback()
public FutureCallback(boolean completed)
public FutureCallback(java.lang.Throwable failed)
public void succeeded()
Callback
Callback invoked when the operation completes.
succeeded
in interface Callback
Callback.failed(Throwable)
public void failed(java.lang.Throwable cause)
Callback
Callback invoked when the operation fails.
public boolean cancel(boolean mayInterruptIfRunning)
cancel
in interface java.util.concurrent.Future<java.lang.Void>
public boolean isCancelled()
isCancelled
in interface java.util.concurrent.Future<java.lang.Void>
public boolean isDone()
isDone
in interface java.util.concurrent.Future<java.lang.Void>
public java.lang.Void get() throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
get
in interface java.util.concurrent.Future<java.lang.Void>
java.lang.InterruptedException
java.util.concurrent.ExecutionException
public java.lang.Void get(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException, java.util.concurrent.TimeoutException
get
in interface java.util.concurrent.Future<java.lang.Void>
java.lang.InterruptedException
java.util.concurrent.ExecutionException
java.util.concurrent.TimeoutException
public static void rethrow(java.util.concurrent.ExecutionException e) throws java.io.IOException
java.io.IOException
public java.lang.String toString()
toString
in class java.lang.Object