diff options
author | michelou <michelou@epfl.ch> | 2006-10-24 11:53:57 +0000 |
---|---|---|
committer | michelou <michelou@epfl.ch> | 2006-10-24 11:53:57 +0000 |
commit | 83fcb4da4e8fef26beaad559c9cb52c4d36fdaca (patch) | |
tree | 86673ec09bddbac8b97320de7295097904dea9fa | |
parent | d3462e7f50ff5c10a562fba44dbe458ec17c35e5 (diff) | |
download | scala-83fcb4da4e8fef26beaad559c9cb52c4d36fdaca.tar.gz scala-83fcb4da4e8fef26beaad559c9cb52c4d36fdaca.tar.bz2 scala-83fcb4da4e8fef26beaad559c9cb52c4d36fdaca.zip |
added Philipp's example to docs/examples/actors/
-rw-r--r-- | docs/examples/actors/Message.scala | 41 |
1 files changed, 41 insertions, 0 deletions
diff --git a/docs/examples/actors/Message.scala b/docs/examples/actors/Message.scala new file mode 100644 index 0000000000..7ec1d503f9 --- /dev/null +++ b/docs/examples/actors/Message.scala @@ -0,0 +1,41 @@ +// Modified by Philipp Haller to use Scala's event-based actors. +package examples.actors + +import scala.actors._ +import scala.actors.Actor._ + +object Message { + def main(args: Array[String]) = { + val n = try { + Integer.parseInt(args(0)) + } + catch { + case _ => + scala.Console.println("Usage: examples.actors.Message <n>") + Predef.exit + } + val nActors = 500 + val finalSum = n * nActors + Scheduler.impl = new SingleThreadedScheduler + + def beh(next: Actor, sum: int): unit = + react { + case value: int => + val j = value + 1; val nsum = sum + j + if (next == null && nsum >= finalSum) { + Console.println(nsum) + System.exit(0) + } + else { + if (next != null) next ! j + beh(next, nsum) + } + } + + def actorChain(i: Int, a: Actor): Actor = + if (i > 0) actorChain(i-1, actor(beh(a, 0))) else a + + val firstActor = actorChain(nActors, null) + var i = n; while (i > 0) { firstActor ! 0; i = i-1 } + } +} |