summaryrefslogtreecommitdiff
path: root/docs
diff options
context:
space:
mode:
authormichelou <michelou@epfl.ch>2006-10-24 11:53:57 +0000
committermichelou <michelou@epfl.ch>2006-10-24 11:53:57 +0000
commit83fcb4da4e8fef26beaad559c9cb52c4d36fdaca (patch)
tree86673ec09bddbac8b97320de7295097904dea9fa /docs
parentd3462e7f50ff5c10a562fba44dbe458ec17c35e5 (diff)
downloadscala-83fcb4da4e8fef26beaad559c9cb52c4d36fdaca.tar.gz
scala-83fcb4da4e8fef26beaad559c9cb52c4d36fdaca.tar.bz2
scala-83fcb4da4e8fef26beaad559c9cb52c4d36fdaca.zip
added Philipp's example to docs/examples/actors/
Diffstat (limited to 'docs')
-rw-r--r--docs/examples/actors/Message.scala41
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 }
+ }
+}