com.bigdata.service.jini.master
Class AbstractAsynchronousClientTask<U,V,L>

java.lang.Object
  com.bigdata.service.FederationCallable<U>
      com.bigdata.service.jini.master.AbstractAsynchronousClientTask<U,V,L>

Type Parameters:

U - The generic type of the Callable's value.

V - The generic type of the resource identifier.

L - The generic type of the client locator.

All Implemented Interfaces:

IFederationCallable, IAsynchronousClientTask<U,V>, Serializable, Remote, Callable<U>

Direct Known Subclasses:

MappedRDFFileLoadTask

public abstract class AbstractAsynchronousClientTask<U,V,L>
extends FederationCallable<U>
implements IAsynchronousClientTask<U,V>

Abstract base class for IAsynchronousClientTask.

See Also:

Serialized Form

Constructor Summary

protected

AbstractAsynchronousClientTask(INotifyOutcome<V,L> proxy)

Method Summary

Future<U>	getFuture() Return a proxy for the future of this task (this allows us to have both the proxy for the task and the proxy for its Future).
INotifyOutcome<V,L>	getNotifyProxy() Return the proxy for the remote object which is notified as asynchronous operations succeed or fail.
void	setFuture(Future<U> future) Set the Future.

Methods inherited from class com.bigdata.service.FederationCallable

getFederation, setFederation

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.bigdata.service.jini.master.IAsynchronousClientTask

accept, close

Methods inherited from interface java.util.concurrent.Callable

call

Constructor Detail

AbstractAsynchronousClientTask

protected AbstractAsynchronousClientTask(INotifyOutcome<V,L> proxy)

Parameters:

proxy - The proxy for the

Method Detail

getNotifyProxy

public INotifyOutcome<V,L> getNotifyProxy()

Return the proxy for the remote object which is notified as asynchronous operations succeed or fail.

getFuture

public Future<U> getFuture()

Description copied from interface: IAsynchronousClientTask

Return a proxy for the future of this task (this allows us to have both the proxy for the task and the proxy for its Future). The Future is required in order to interrupt the client tasks when the MappedTaskMaster terminates.

Specified by:

getFuture in interface IAsynchronousClientTask<U,V>

setFuture

public final void setFuture(Future<U> future)

Set the Future.

Parameters:

future - The future for this callable.

Throws:

IllegalArgumentException - if the future is null.

IllegalStateException - if the future has been set to a different value.