summaryrefslogtreecommitdiff
path: root/docs/examples/actors/links.scala
diff options
context:
space:
mode:
Diffstat (limited to 'docs/examples/actors/links.scala')
-rw-r--r--docs/examples/actors/links.scala47
1 files changed, 47 insertions, 0 deletions
diff --git a/docs/examples/actors/links.scala b/docs/examples/actors/links.scala
new file mode 100644
index 0000000000..149f6db159
--- /dev/null
+++ b/docs/examples/actors/links.scala
@@ -0,0 +1,47 @@
+package examples.actors
+
+import scala.actors.{Actor, Exit}
+import scala.actors.Actor._
+
+object links extends Application {
+
+ case object Stop
+
+ actor {
+ val start = link(p(2))
+ start ! Stop
+ }
+
+ def p(n: int): Actor =
+ if (n == 0) top1()
+ else top(p(n-1), n)
+
+ def top(a: Actor, n: int): Actor = actor {
+ Console.println("starting actor " + n + " (" + Thread.currentThread() + ")")
+ self.trapExit = true
+ link(a)
+ loop {
+ receive {
+ case ex @ Exit(from, reason) =>
+ Console.println("Actor " + n + " received " + ex)
+ exit("finished")
+ case any => {
+ Console.println("Actor " + n + " received " + any)
+ a ! any
+ }
+ }
+ }
+ }
+
+ def top1(): Actor = actor {
+ Console.println("starting last actor" + " (" + Thread.currentThread() + ")")
+ receive {
+ case Stop =>
+ Console.println("Last actor now exiting")
+ exit("abnormal")
+ case any =>
+ Console.println("Last actor received " + any)
+ top1()
+ }
+ }
+}