Package org.apache.ignite.lang
Interface IgniteFuture<V>
- 
- Type Parameters:
- V- Type of the result for the future.
 - All Known Subinterfaces:
- ComputeTaskFuture<R>,- SchedulerFuture<R>
 
 public interface IgniteFuture<V>Future with simplified exception handling, functional programming support and ability to listen for future completion via functional callback.
- 
- 
Method SummaryAll Methods Instance Methods Abstract Methods Modifier and Type Method Description booleancancel()Cancels this future.<T> IgniteFuture<T>chain(IgniteClosure<? super IgniteFuture<V>,T> doneCb)Make a chained future to convert result of this future (when complete) into a new format.<T> IgniteFuture<T>chainAsync(IgniteClosure<? super IgniteFuture<V>,T> doneCb, Executor exec)Make a chained future to convert result of this future (when complete) into a new format.Vget()Synchronously waits for completion of the computation and returns computation result.Vget(long timeout)Synchronously waits for completion of the computation for up to the timeout specified and returns computation result.Vget(long timeout, TimeUnit unit)Synchronously waits for completion of the computation for up to the timeout specified and returns computation result.booleanisCancelled()Returnstrueif this task was cancelled before it completed normally.booleanisDone()Returnstrueif this task completed.voidlisten(IgniteInClosure<? super IgniteFuture<V>> lsnr)Registers a callback to be invoked when the future completes.voidlistenAsync(IgniteInClosure<? super IgniteFuture<V>> lsnr, Executor exec)Registers a callback to be invoked with the specified executor when the future completes.
 
- 
- 
- 
Method Detail- 
getV get() throws IgniteException Synchronously waits for completion of the computation and returns computation result.- Returns:
- Computation result.
- Throws:
- IgniteInterruptedException- Subclass of- IgniteExceptionthrown if the wait was interrupted.
- IgniteFutureCancelledException- Subclass of- IgniteExceptionthrown if computation was cancelled.
- IgniteException- If computation failed.
 
 - 
getV get(long timeout) throws IgniteException Synchronously waits for completion of the computation for up to the timeout specified and returns computation result. This method is equivalent to callingget(long, TimeUnit.MILLISECONDS).- Parameters:
- timeout- The maximum time to wait in milliseconds.
- Returns:
- Computation result.
- Throws:
- IgniteInterruptedException- Subclass of- IgniteExceptionthrown if the wait was interrupted.
- IgniteFutureCancelledException- Subclass of- IgniteExceptionthrown if computation was cancelled.
- IgniteFutureTimeoutException- Subclass of- IgniteExceptionthrown if the wait was timed out.
- IgniteException- If computation failed.
 
 - 
getV get(long timeout, TimeUnit unit) throws IgniteException Synchronously waits for completion of the computation for up to the timeout specified and returns computation result.- Parameters:
- timeout- The maximum time to wait.
- unit- The time unit of the- timeoutargument.
- Returns:
- Computation result.
- Throws:
- IgniteInterruptedException- Subclass of- IgniteExceptionthrown if the wait was interrupted.
- IgniteFutureCancelledException- Subclass of- IgniteExceptionthrown if computation was cancelled.
- IgniteFutureTimeoutException- Subclass of- IgniteExceptionthrown if the wait was timed out.
- IgniteException- If computation failed.
 
 - 
cancelboolean cancel() throws IgniteExceptionCancels this future.- Returns:
- Trueif future was canceled (i.e. was not finished prior to this call).
- Throws:
- IgniteException- If cancellation failed.
 
 - 
isCancelledboolean isCancelled() Returnstrueif this task was cancelled before it completed normally.- Returns:
- trueif this task was cancelled before it completed
 
 - 
isDoneboolean isDone() Returnstrueif this task completed.Completion may be due to normal termination, an exception, or cancellation - in all of these cases, this method will return true.- Returns:
- trueif this task completed.
 
 - 
listenvoid listen(IgniteInClosure<? super IgniteFuture<V>> lsnr) Registers a callback to be invoked when the future completes. If the future is already completed, callback will be invoked immediately in the current thread.- Parameters:
- lsnr- Listener closure to register. Cannot be- null.
 
 - 
listenAsyncvoid listenAsync(IgniteInClosure<? super IgniteFuture<V>> lsnr, Executor exec) Registers a callback to be invoked with the specified executor when the future completes.- Parameters:
- lsnr- Listener closure to register. Cannot be- null.
- exec- Executor to invoke the listener. Cannot be- null.
 
 - 
chain<T> IgniteFuture<T> chain(IgniteClosure<? super IgniteFuture<V>,T> doneCb) Make a chained future to convert result of this future (when complete) into a new format. It is guaranteed that done callback will be called only ONCE.- Type Parameters:
- T- Type of the converted result.
- Parameters:
- doneCb- Done callback that is applied to this future when it finishes to produce chained future result.
- Returns:
- Chained future that finishes after this future completes and done callback is called.
 
 - 
chainAsync<T> IgniteFuture<T> chainAsync(IgniteClosure<? super IgniteFuture<V>,T> doneCb, Executor exec) Make a chained future to convert result of this future (when complete) into a new format. It is guaranteed that done callback will be called only ONCE.- Type Parameters:
- T- Type of the converted result.
- Parameters:
- doneCb- Done callback that is applied to this future when it finishes to produce chained future result.
- exec- Executor to run done callback. Cannot be- null.
- Returns:
- Chained future that finishes after this future completes and done callback is called.
 
 
- 
 
-