org.spf4j.concurrent

Class FutureBean<T>

java.lang.Object

org.spf4j.concurrent.FutureBean<T>

All Implemented Interfaces:

Future<T>

@ThreadSafe
public class FutureBean<T>
extends Object
implements Future<T>

bean like implementation of a future

Author:

zoly

Constructor Summary

Constructors

Constructor and Description
FutureBean()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
void	done()
T	get()
T	get(long timeout, TimeUnit unit)
Either<T,? extends ExecutionException>	getResultStore()
boolean	isCancelled()
boolean	isDone()
static <T> T	processResult(Either<T,? extends ExecutionException> result)
void	setExceptionResult(ExecutionException result)
void	setResult(T result)

Methods inherited from class java.lang.Object

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

Constructor Detail

FutureBean

public FutureBean()

Method Detail

cancel

public final boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<T>

isCancelled

public final boolean isCancelled()

Specified by:

isCancelled in interface Future<T>

isDone

public final boolean isDone()

Specified by:

isDone in interface Future<T>

getResultStore

public final Either<T,? extends ExecutionException> getResultStore()

get

public final T get()
            throws InterruptedException,
                   ExecutionException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

get

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

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

TimeoutException

processResult

public static <T> T processResult(Either<T,? extends ExecutionException> result)
                       throws ExecutionException

Throws:

ExecutionException

setResult

public final void setResult(T result)

setExceptionResult

public final void setExceptionResult(ExecutionException result)

done

public void done()