diff options
Diffstat (limited to 'docs/examples/actors/links.scala')
-rw-r--r-- | docs/examples/actors/links.scala | 47 |
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() + } + } +} |