raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Adding Pi2, fixing router shutdown in Pi, cleaning up the generation of workers in Pi

Browse source
This commit is contained in:
Viktor Klang 2011-04-02 15:22:38 +02:00
parent 64d620c7b1
commit c14c01a53c
2 changed files with 135 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

9
akka-tutorials/akka-tutorial-pi-sbt/src/main/scala/Pi.scala
View file

@ -66,11 +66,7 @@ object Pi {
var start: Long = _
// create the workers
val workers = {
var ws = Vector[ActorRef]()
for (i <- 0 until nrOfWorkers) ws = ws :+ actorOf[Worker].start
ws
}
val workers = Vector.fill(nrOfWorkers)(actorOf[Worker].start)
// wrap them with a load-balancing router
val router = Routing.loadBalancerActor(CyclicIterator(workers)).start
@ -84,6 +80,9 @@ object Pi {
// send a PoisonPill to all workers telling them to shut down themselves
router ! Broadcast(PoisonPill)
// send a PoisonPill to the router, telling him to shut himself down
router ! PoisonPill
case Result(value) =>
// handle result from the worker
pi += value