Package de.unistuttgart.isw.sfsc.commonjava.util

Class FutureAdapter<T,U>

java.lang.Object

de.unistuttgart.isw.sfsc.commonjava.util.FutureAdapter<T,U>

All Implemented Interfaces:

Future<U>

public class FutureAdapter<T,U>
extends Object
implements Future<U>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	FutureAdapter.ThrowingFunction<T,U>

Constructor Summary

Constructors

Constructor	Description
FutureAdapter(FutureAdapter.ThrowingFunction<T,U> converter, Callable<U> errorHandler)

Method Summary

Modifier and Type	Method	Description
boolean	cancel(boolean mayInterruptIfRunning)
U	get()
U	get(long timeout, TimeUnit unit)
void	handleError()
void	handleInput(T input)
boolean	isCancelled()
boolean	isDone()

Methods inherited from class java.lang.Object

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

Constructor Detail

FutureAdapter

public FutureAdapter(FutureAdapter.ThrowingFunction<T,U> converter,
                     Callable<U> errorHandler)

Method Detail

handleInput

public void handleInput(T input)

handleError

public void handleError()

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

public U get()
      throws InterruptedException,
             ExecutionException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

get

public U get(long timeout,
             TimeUnit unit)
      throws InterruptedException,
             ExecutionException,
             TimeoutException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

TimeoutException