diff options
author | Philipp Haller <hallerp@gmail.com> | 2007-02-02 15:17:51 +0000 |
---|---|---|
committer | Philipp Haller <hallerp@gmail.com> | 2007-02-02 15:17:51 +0000 |
commit | 7cc5c06947e40236ee16a6a09d3de524183fda86 (patch) | |
tree | 8b22f79f79ffcb4b8485a3c6b21380efdc66d903 /docs/examples/actors/links.scala | |
parent | 8c1bbafee4c68ccd158786deb4643d5a3074ce0d (diff) | |
download | scala-7cc5c06947e40236ee16a6a09d3de524183fda86.tar.gz scala-7cc5c06947e40236ee16a6a09d3de524183fda86.tar.bz2 scala-7cc5c06947e40236ee16a6a09d3de524183fda86.zip |
Cleaned-up actor examples.
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() + } + } +} |