U- The generic type of the
Callable's aggregate result.
V- The generic type of the resources in the chunk.
public interface IAsynchronousClientTask<U,V> extends Remote
Callables which process chunks of resources as assigned by the MappedTaskMaster. This interface extends
Remotesince its methods are invoked using RMI.
|Modifier and Type||Method and Description|
Accept a chunk of resources for processing.
Signal that no new chunks will be tasked to client.
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
void accept(V chunk) throws RemoteException, InterruptedException
void close() throws RemoteException, InterruptedException
Callable.call()until the master interrupts the client using
Future.cancel(boolean). However, if all work is complete, then the client MAY interrupt the main thread.
Future<U> getFuture() throws RemoteException
Futureis required in order to interrupt the client tasks when the MappedTaskMaster terminates.
Copyright © 2006–2016 SYSTAP, LLC DBA Blazegraph. All rights reserved.