Package org.threadly.concurrent.future

Implementations of different futures as well as utilities for handling futures.

See: Description

Interface Summary

Interface	Description
FutureCallback<T>	Callback for accepting the results of a future once the future has completed.
ListenableFuture<T>	Future where you can add a listener which is called once the future has completed.
ListenableRunnableFuture<T>	This is a ListenableFuture which can be executed.
ListenableScheduledFuture<T>	Deprecated Replaced with org.threadly.concurrent.wrapper.compatibility.ListenableScheduledFuture

Class Summary

Class	Description
AbstractFutureCallbackFailureHandler	Deprecated Instead use a Consumer provided to ListenableFuture.failureCallback(java.util.function.Consumer)
AbstractFutureCallbackResultHandler<T>	Deprecated Instead use a Consumer provided to ListenableFuture.resultCallback(java.util.function.Consumer)
CancelDebuggingListenableFuture<T>	Wrapper for a ListenableFuture to provide enhanced features for debugging the state at which at which it was canceled.
ExecuteOnGetFutureTask<T>	This future task has a special ability to start execution in the thread requesting the ExecuteOnGetFutureTask.get() IF it has not already started.
FutureCallbackExceptionHandlerAdapter	Deprecated Instead provide the ExceptionHandler directly into ListenableFuture.failureCallback(java.util.function.Consumer)
FutureCallbackFailureHandler	Deprecated Instead provide Consumer directly to ListenableFuture.failureCallback(java.util.function.Consumer)
FutureCallbackResultHandler<T>	Deprecated Instead provide Consumer directly to ListenableFuture.resultCallback(java.util.function.Consumer)
FutureUtils	A collection of small utilities for handling futures.
ImmediateFailureListenableFuture<T>	Completed implementation of ListenableFuture that will immediately provide a failure condition.
ImmediateResultListenableFuture<T>	Completed implementation of ListenableFuture that will immediately return a result.
ListenableFutureAdapterTask<T>	Adapter from java's Future to threadly's ListenableFuture.
ListenableFutureTask<T>	This is a future which can be executed.
RunnableFutureCallbackAdapter<T>	Deprecated To be removed without replacement, if you use this, open an issue on github
ScheduledFutureDelegate<T>	Deprecated To be removed without public replacement, if used please open github issue
SettableListenableFuture<T>	This class is designed to be a helper when returning a single result asynchronously.
Watchdog	This class is to guarantee that a given ListenableFuture is completed within a timeout.
WatchdogCache	A class which handles a collection of Watchdog instances.

Enum Summary

Enum	Description
ListenableFuture.ListenerOptimizationStrategy	Strategy to use for optimizing listener execution.

Exception Summary

Exception	Description
CancelDebuggingListenableFuture.FutureProcessingStack	Throwable that is not thrown, but instead added as a cause to indicate the processing stack trace at the time of cancellation.

Package org.threadly.concurrent.future Description

Implementations of different futures as well as utilities for handling futures.