From 60b3d90f81cf3f83440725a02afc7dc693fa9ea5 Mon Sep 17 00:00:00 2001 From: Philipp Haller Date: Fri, 29 Sep 2006 16:50:44 +0000 Subject: Checked in examples for new actors lib. --- docs/examples/actors/RemoteCounter.scala | 45 ++++++++++++++++++++++++++++++++ 1 file changed, 45 insertions(+) create mode 100644 docs/examples/actors/RemoteCounter.scala (limited to 'docs/examples/actors/RemoteCounter.scala') diff --git a/docs/examples/actors/RemoteCounter.scala b/docs/examples/actors/RemoteCounter.scala new file mode 100644 index 0000000000..b52259b6c2 --- /dev/null +++ b/docs/examples/actors/RemoteCounter.scala @@ -0,0 +1,45 @@ +package examples.actors + +import scala.actors.Actor._ +import scala.actors.RemoteActor._ +import scala.actors.{Actor,TcpNode} + +case object Incr +case object Value +case class Result(v: int) + +object RemoteCounter extends Application { + actor { + def loop(value: int): unit = { + Console.println("Value: " + value) + receive { + case Incr => loop(value + 1) + case Value => { sender ! Result(value); loop(value) } + case other => loop(value) + } + } + + alive(9010) + register('counter, self) + loop(0) + } + + actor { + val c = select(TcpNode("127.0.0.1", 9010), 'counter) + + c ! Incr + c ! Incr + + try { Thread.sleep(1000) } catch { + case ie: InterruptedException => + } + + c ! Value + receive { + case Result(v) => { + Console.println("Received result: " + v) + sender ! Incr + } + } + } +} -- cgit v1.2.3