|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--org.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. |
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 |
void |
receiveFuture(Future futureObject)
To put a future in the FutureMap |
void |
receiveFutureValue(long id,
UniqueID creatorID,
java.lang.Object result)
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()
|
void |
setMigrationTag()
|
void |
setOwnerBody(UniqueID i)
Setter of the ID of the body corresonding to this FuturePool |
void |
unsetMigrationTag()
|
void |
waitForReply()
|
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 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 void receiveFutureValue(long id, UniqueID creatorID, java.lang.Object result) 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()
public void registerDestination(UniversalBody dest)
public void removeDestination()
public void setMigrationTag()
public void unsetMigrationTag()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |