|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectappl.parallel.spmd.SPMDClientController
appl.parallel.spmd.AdvancedSPMDClientController
public class AdvancedSPMDClientController
Performance optimizations on client side can be made with this class. Allows
heavy multithreading.
Merging can be done in a separate thread (parallel to further computation)
for details on the usage of a client controller
Nested Class Summary |
---|
Nested classes/interfaces inherited from class appl.parallel.spmd.SPMDClientController |
---|
SPMDClientController.STATE |
Field Summary |
---|
Fields inherited from class appl.parallel.spmd.SPMDClientController |
---|
referenceResourceID |
Constructor Summary | |
---|---|
AdvancedSPMDClientController(Vector<ComputingResourceContainer> computingResources,
double[] weights,
ClientDataServer spmdClient,
CommEventSink eventProxy)
same parameters as superclass |
Method Summary | |
---|---|
void |
mergeMultiData(MultiDataObject multidata,
int idx,
SyncPoint s)
Merges like SPMDClientController.mergeMultiData(MultiDataObject, int) . |
void |
mergeMultiData(MultiDataObject multidata,
int idx,
SyncPoint s,
PrintStream stream,
String message)
Merges like SPMDClientController.mergeMultiData(MultiDataObject, int) . |
void |
mergePartition(Object partition,
SyncPoint s)
Merges like SPMDClientController.mergePartition(int) , but in a
separate thread, so that communication does not block computation. |
void |
mergePartition(Object partition,
SyncPoint s,
PrintStream stream,
String message)
Same functionality as AdvancedSPMDClientInterface.mergePartition(Object, SyncPoint) , gives
a message to the given PrintStream |
void |
synchronizeToSyncPoint(SyncPoint s)
Waits until the Thread with the specified SyncPoint finishes. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface appl.parallel.spmd.SPMDClientInterface |
---|
addBaseParameter, addBaseParameters, addToMultiDataSplitControl, addToMultiDataSplitControl, addToSplitControl, mergeAllPartitions, mergeMultiData, mergeMultiData, mergePartition, mergePartition, runSPMDModelTask, setBoxingMode, setNeighborhoodRange, setReferenceResource, updateNeighborhood, updateNeighborhood |
Constructor Detail |
---|
public AdvancedSPMDClientController(Vector<ComputingResourceContainer> computingResources, double[] weights, ClientDataServer spmdClient, CommEventSink eventProxy)
SPMDClientController.SPMDClientController(Vector, double[],
ClientDataServer, CommEventSink)
Method Detail |
---|
public void mergePartition(Object partition, SyncPoint s, PrintStream stream, String message)
AdvancedSPMDClientInterface
AdvancedSPMDClientInterface.mergePartition(Object, SyncPoint)
, gives
a message to the given PrintStream
mergePartition
in interface AdvancedSPMDClientInterface
partition
- the partition to merges
- a SyncPoint
stream
- the message is given out to this stream (or null for no
message)message
- the message to be displayed when finished (or null for no
message)AdvancedSPMDClientInterface.mergeMultiData(MultiDataObject, int, SyncPoint)
public void mergePartition(Object partition, SyncPoint s)
AdvancedSPMDClientInterface
SPMDClientController.mergePartition(int)
, but in a
separate thread, so that communication does not block computation. See
also synchronization points
mergePartition
in interface AdvancedSPMDClientInterface
partition
- the partition to be merged (must be splittable)s
- a syncpointpublic void mergeMultiData(MultiDataObject multidata, int idx, SyncPoint s, PrintStream stream, String message)
AdvancedSPMDClientInterface
SPMDClientController.mergeMultiData(MultiDataObject, int)
. But
allows also synchronization points
. At the end of the
merge a message is given to the provided PrintStream
.
mergeMultiData
in interface AdvancedSPMDClientInterface
multidata
- the multidataobjectidx
- the partition of the MultiDataObject
to be mergeds
- a SyncPoint
stream
- the message is given out to this stream (or null for no
message)message
- the message to be diplayed when finished (or null for no
message)public void mergeMultiData(MultiDataObject multidata, int idx, SyncPoint s)
AdvancedSPMDClientInterface
SPMDClientController.mergeMultiData(MultiDataObject, int)
. But
allows also synchronization points
mergeMultiData
in interface AdvancedSPMDClientInterface
multidata
- the multidataobjectidx
- the partition of the MultiDataObject
to be mergeds
- a SyncPoint
public void synchronizeToSyncPoint(SyncPoint s)
AdvancedSPMDClientInterface
synchronizeToSyncPoint
in interface AdvancedSPMDClientInterface
s
- the SyncPoint
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |