|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.proactive.core.body.future.FuturePool
Field Summary | |
protected boolean |
newState
|
Constructor Summary | |
FuturePool()
|
Method Summary | |
void |
addAutomaticContinuation(long id,
UniqueID creatorID,
UniversalBody bodyDest)
To add an automatic contiunation, ie a destination body, for a particular future. |
static void |
addMeAsBodyForwarder()
|
void |
disableAC()
To disable the automatic continuation behaviour for all futures in this FuturePool |
void |
enableAC()
To enable the automatic continuation behaviour for all futures in this FuturePool |
static UniversalBody |
getBodyDestination()
|
static java.util.ArrayList |
getIncomingFutures()
|
UniqueID |
getOwnerBody()
Getter of the ID of the body corresonding to this FuturePool |
static boolean |
isInsideABodyForwarder()
|
void |
receiveFuture(Future futureObject)
To put a future in the FutureMap |
int |
receiveFutureValue(long id,
UniqueID creatorID,
FutureResult result,
Reply reply)
Method called when a reply is recevied, ie a value is available for a future. |
static void |
registerBodyDestination(UniversalBody dest)
|
void |
registerDestination(UniversalBody dest)
To register a destination before sending a reques or a reply Registration key is the calling thread. |
static void |
registerIncomingFuture(Future f)
|
static void |
removeBodyDestination()
|
void |
removeDestination()
To clear registred destination for the calling thread. |
static void |
removeIncomingFutures()
|
static void |
removeMeFromBodyForwarders()
|
void |
setMigrationTag()
|
void |
setOwnerBody(UniqueID i)
Setter of the ID of the body corresonding to this FuturePool |
void |
startACThread()
Start the AC thread if Automatic continuation mechanism is enable |
void |
unsetMigrationTag()
|
void |
waitForReply(long timeout)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected boolean newState
Constructor Detail |
public FuturePool()
Method Detail |
public static void addMeAsBodyForwarder()
public static void removeMeFromBodyForwarders()
public static boolean isInsideABodyForwarder()
public static void registerBodyDestination(UniversalBody dest)
public static void removeBodyDestination()
public static UniversalBody getBodyDestination()
public static void registerIncomingFuture(Future f)
public static void removeIncomingFutures()
public static java.util.ArrayList getIncomingFutures()
public void setOwnerBody(UniqueID i)
i
- ID of the owner body.public UniqueID getOwnerBody()
public void enableAC()
public void disableAC()
public int receiveFutureValue(long id, UniqueID creatorID, FutureResult result, Reply reply) throws java.io.IOException
id
- sequence id of the future to updatecreatorID
- ID of the body creator of the future to updateresult
- value to update with the futures
java.io.IOException
public void receiveFuture(Future futureObject)
futureObject
- future to registerpublic void addAutomaticContinuation(long id, UniqueID creatorID, UniversalBody bodyDest)
id
- sequence id of the corresponding futurecreatorID
- UniqueID of the body which creates futureObjectbodyDest
- body destination of this continuationpublic void waitForReply(long timeout) throws ProActiveException
ProActiveException
public void registerDestination(UniversalBody dest)
public void removeDestination()
public void setMigrationTag()
public void unsetMigrationTag()
public void startACThread()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |