public class Master extends akka.actor.UntypedActor
Workto one or more slaves and forwards
Results to a predefined accumulator. Also forwards work and results to the failure detector, which will keep track of their relative timings and if it expires, send back the work to the master to be re-sent to a delegate. Clients can first send their work and then send ('ask') the
GetResultsmessage, which will cause the
Resultto be returned when it is computed.
|Modifier and Type||Class and Description|
Defines objects that create
|Constructor and Description|
Creates a new instance with the given supervisor, the given slaves and a failure detector of the given type.
|Modifier and Type||Method and Description|
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, getContext, getSelf, getSender, postRestart, postStop, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled
public Master(int queueSize, List<akka.actor.ActorRef> slaves, boolean repeatable, akka.actor.Props accumulatorProps, Master.MasterAwareProps failureDetectorProps)
queueSize- the target size of the work queue per remote client
slaves- the actors to which to delegate the work
repeatable- whether the simulation has to be repeatable
accumulatorProps- the properties of the accumulator that is to be created
failureDetectorProps- the properties of the failure detector
Copyright © 2010-2016 Numerical Method Incorporation Limited. All Rights Reserved.