org.threadly.concurrent.future

Class ListenableFutureAdapterTask<T>

java.lang.Object

java.util.concurrent.FutureTask<T>

org.threadly.concurrent.future.ListenableFutureTask<T>

org.threadly.concurrent.future.ListenableFutureAdapterTask<T>

Type Parameters:

T - Type of result returned from the future

All Implemented Interfaces:

java.lang.Runnable, java.util.concurrent.Future<T>, java.util.concurrent.RunnableFuture<T>, CallableContainer<T>, ListenableFuture<T>, ListenableRunnableFuture<T>

public class ListenableFutureAdapterTask<T>
extends ListenableFutureTask<T>

Adapter from java's Future to threadly's ListenableFuture. This transfers the state (ie result, failure, or canceled) from the source future. In order for this translation to occur a thread is needed to notify potential listeners when the future completes. When ListenableFutureTask.run() is invoked we will block (if delegate future is not complete) waiting for the result from the provided future. Completing with the same state once the provided future completes.

The most common way to use this class is to construct it with the future to adapt from, then provide this future to an executor to block waiting for the provided future to complete. If this is used for high quantities keep in mind a lot of the threads will idly be waiting for results, typically a native threadly pool may be a better option.

Since:

4.9.0

Nested Class Summary

Nested classes/interfaces inherited from interface org.threadly.concurrent.future.ListenableFuture

ListenableFuture.ListenerOptimizationStrategy

Constructor Summary

Constructors

Constructor and Description
ListenableFutureAdapterTask(java.util.concurrent.Future<? extends T> f) Constructs a new ListenableFutureAdapterTask.

Method Summary

Modifier and Type	Method and Description
void	run()

Methods inherited from class org.threadly.concurrent.future.ListenableFutureTask

addListener, getContainedCallable

Methods inherited from class java.util.concurrent.FutureTask

cancel, get, get, isCancelled, isDone

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.threadly.concurrent.future.ListenableFuture

addCallback, addCallback, addCallback, addListener, addListener, flatMap, flatMap, flatMap, map, map, map

Methods inherited from interface java.util.concurrent.Future

cancel, get, get, isCancelled, isDone

Constructor Detail

ListenableFutureAdapterTask

public ListenableFutureAdapterTask(java.util.concurrent.Future<? extends T> f)

Constructs a new ListenableFutureAdapterTask.

Parameters:

f - Future to get result and source final state from

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

Specified by:

run in interface java.util.concurrent.RunnableFuture<T>

Overrides:

run in class ListenableFutureTask<T>