net.tomp2p.futures
Class FutureTask

java.lang.Object
  net.tomp2p.futures.BaseFutureImpl<FutureTask>
      net.tomp2p.futures.FutureTask

All Implemented Interfaces:

BaseFuture, Cancellable

public class FutureTask
extends BaseFutureImpl<FutureTask>

This future keeps track of one or more tasks send to remote peers.

Author:

Thomas Bocek

Nested Class Summary

Nested classes/interfaces inherited from interface net.tomp2p.futures.BaseFuture

BaseFuture.FutureType

Field Summary

Fields inherited from class net.tomp2p.futures.BaseFutureImpl

completed, lock, reason, type

Constructor Summary

FutureTask()

Method Summary

void	addRequests(FutureAsyncTask futureResponse) Adds all requests that have been created for the DHT operations.
int	getFailureCount()
Map<PeerAddress,Map<Number160,Data>>	getRawDataMap()
int	getSuccessCount()
void	setDone() Finishes the future.
void	setProgress(FutureAsyncTask futureAsyncTask) This is called for intermediate results.

Methods inherited from class net.tomp2p.futures.BaseFutureImpl

addCancellation, addListener, addListener, await, await, awaitListeners, awaitUninterruptibly, awaitUninterruptibly, cancel, getFailedReason, getType, isCompleted, isFailed, isSuccess, notifyListerenrs, removeListener, self, setCompletedAndNotify, setFailed, setFailed, setFailed, setFailed, setFailed

Methods inherited from class java.lang.Object

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

Constructor Detail

FutureTask

public FutureTask()

Method Detail

addRequests

public void addRequests(FutureAsyncTask futureResponse)

Adds all requests that have been created for the DHT operations. Those were created after the routing process.

Parameters:

futureResponse - The futurRepsonse that has been created

setDone

public void setDone()

Finishes the future. Set the future to success if at least one of the future was a success.

setProgress

public void setProgress(FutureAsyncTask futureAsyncTask)

This is called for intermediate results. Whenever a FutureAsyncTask is ready, update the result data.

Parameters:

futureAsyncTask - The future that has finished

getRawDataMap

public Map<PeerAddress,Map<Number160,Data>> getRawDataMap()

getSuccessCount

public int getSuccessCount()

getFailureCount

public int getFailureCount()