Package org.springframework.util.concurrent

Class FutureAdapter<T,S>

java.lang.Object

org.springframework.util.concurrent.FutureAdapter<T,S>

Type Parameters:

T - the type of this Future

S - the type of the adaptee's Future

All Implemented Interfaces:

Future<T>

Direct Known Subclasses:

ListenableFutureAdapter

public abstract class FutureAdapter<T,S>
extends Object
implements Future<T>

Abstract class that adapts a Future parameterized over S into a Future parameterized over T. All methods are delegated to the adaptee, where get() and get(long, TimeUnit) call adapt(Object) on the adaptee's result.

Since:

4.0

Author:

Arjen Poutsma

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	FutureAdapter(Future<S> adaptee)	Constructs a new FutureAdapter with the given adaptee.

Method Summary

Modifier and Type	Method	Description
protected abstract T	adapt(S adapteeResult)	Adapts the given adaptee's result into T.
boolean	cancel(boolean mayInterruptIfRunning)
T	get()
T	get(long timeout, TimeUnit unit)
protected Future<S>	getAdaptee()	Returns the adaptee.
boolean	isCancelled()
boolean	isDone()

Methods inherited from class java.lang.Object

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

Constructor Details

FutureAdapter

protected FutureAdapter(Future<S> adaptee)

Constructs a new FutureAdapter with the given adaptee.

Parameters:

adaptee - the future to delegate to

Method Details

getAdaptee

protected Future<S> getAdaptee()

Returns the adaptee.

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<T>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<T>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<T>

get

@Nullable
public T get()
      throws InterruptedException,
ExecutionException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

get

@Nullable
public T get(long timeout,
 TimeUnit unit)
      throws InterruptedException,
ExecutionException,
TimeoutException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

TimeoutException

adapt

@Nullable
protected abstract T adapt(S adapteeResult)
                    throws ExecutionException

Adapts the given adaptee's result into T.

Returns:

the adapted result

Throws:

ExecutionException