Promise.Adapter<U>, Promise.Completable<S>, Promise.Wrapper<W>
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 C |
_result |
private static java.lang.Throwable |
COMPLETED |
Constructor and Description |
---|
FuturePromise() |
FuturePromise(C result) |
FuturePromise(C ctx,
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.
|
C |
get() |
C |
get(long timeout,
java.util.concurrent.TimeUnit unit) |
boolean |
isCancelled() |
boolean |
isDone() |
static void |
rethrow(java.util.concurrent.ExecutionException e) |
void |
succeeded(C result)
Callback invoked when the operation completes.
|
java.lang.String |
toString() |
private static java.lang.Throwable COMPLETED
private final java.util.concurrent.atomic.AtomicBoolean _done
private final java.util.concurrent.CountDownLatch _latch
private java.lang.Throwable _cause
private C _result
public FuturePromise()
public FuturePromise(C result)
public FuturePromise(C ctx, java.lang.Throwable failed)
public void succeeded(C result)
Promise
Callback invoked when the operation completes.
succeeded
in interface Promise<C>
result
- the contextPromise.failed(Throwable)
public void failed(java.lang.Throwable cause)
Promise
Callback invoked when the operation fails.
public boolean cancel(boolean mayInterruptIfRunning)
cancel
in interface java.util.concurrent.Future<C>
public boolean isCancelled()
isCancelled
in interface java.util.concurrent.Future<C>
public boolean isDone()
isDone
in interface java.util.concurrent.Future<C>
public C get() throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
get
in interface java.util.concurrent.Future<C>
java.lang.InterruptedException
java.util.concurrent.ExecutionException
public C 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<C>
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