com.bigdata.service.proxy

Class ThickFuture<V>

java.lang.Object

com.bigdata.service.proxy.ThickFuture<V>

All Implemented Interfaces:

Serializable, Future<V>

public class ThickFuture<V>
extends Object
implements Future<V>, Serializable

A thick Future. This is used to communicate the state of a Future to a remote client. The constructor blocks until the Future is done and then makes a record of the Future's state. That state is serializable as the object returned by the Future is serializable.

Version:

$Id$

Author:

Bryan Thompson

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ThickFuture(Future<V> f) Awaits the Future and then makes a serializable record of the Future's state.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
V	get()
V	get(long timeout, TimeUnit unit)
boolean	isCancelled()
boolean	isDone()

Methods inherited from class java.lang.Object

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

Constructor Detail

ThickFuture

public ThickFuture(Future<V> f)

Awaits the Future and then makes a serializable record of the Future's state.

Method Detail

cancel

public final boolean cancel(boolean mayInterruptIfRunning)

The future can not be cancelled as it is already done.

Specified by:

cancel in interface Future<V>

isCancelled

public final boolean isCancelled()

Specified by:

isCancelled in interface Future<V>

isDone

public final boolean isDone()

Always returns true.

Specified by:

isDone in interface Future<V>

get

public final V get()
            throws InterruptedException,
                   ExecutionException

The Future is already done, so this method does not block.

Specified by:

get in interface Future<V>

Throws:

InterruptedException

ExecutionException

get

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

The Future is already done, so this method does not block.

Specified by:

get in interface Future<V>

Throws:

InterruptedException

ExecutionException

TimeoutException