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

Move Timeout into actor package to make more accessible, use overloaded '?' method to handle explicit Timeout

Browse source
This commit is contained in:
Derek Williams 2011-06-28 15:20:31 -06:00
parent 81b361e6d7
commit ccb8440912
10 changed files with 48 additions and 51 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-tutorials/akka-tutorial-second/src/main/scala/Pi.scala
View file

@ -8,7 +8,7 @@ import akka.actor.Actor._
import akka.routing.{Routing, CyclicIterator}
import Routing._
import akka.event.EventHandler
import akka.actor.{Channel, Actor, PoisonPill}
import akka.actor.{Channel, Actor, PoisonPill, Timeout}
import akka.dispatch.Future
import System.{currentTimeMillis => now}
@ -104,7 +104,7 @@ object Pi extends App {
val start = now
//send calculate message
master.?(Calculate, Actor.Timeout(60000)).
master.?(Calculate, Timeout(60000)).
await.resultOrException match {//wait for the result, with a 60 seconds timeout
case Some(pi) =>
EventHandler.info(this, "\n\tPi estimate: \t\t%s\n\tCalculation time: \t%s millis".format(pi, (now - start)))