diff options
Diffstat (limited to 'docs/examples/actors/counter.scala')
-rw-r--r-- | docs/examples/actors/counter.scala | 62 |
1 files changed, 0 insertions, 62 deletions
diff --git a/docs/examples/actors/counter.scala b/docs/examples/actors/counter.scala deleted file mode 100644 index e768a8f9ef..0000000000 --- a/docs/examples/actors/counter.scala +++ /dev/null @@ -1,62 +0,0 @@ -/** - * @author Philipp Haller <philipp.haller@epfl.ch> - */ - -package examples.actors - -import scala.actors.Process -import scala.actors.distributed.{RemoteActor,TCP,TcpNode,TcpService} - -case class Incr() -case class Value(p: Process) -case class Result(v: int) - -class Counter extends RemoteActor { - override def run(): unit = - loop(0) - - def loop(value: int): unit = { - Console.println("Value: " + value) - receive { - case Incr() => - loop(value + 1) - case Value(p) => - p ! Result(value) - loop(value) - case other => - loop(value) - } - } -} - -class CounterUser extends RemoteActor { - override def run(): unit = { - alive(TCP()) - - val host = java.net.InetAddress.getLocalHost().getHostAddress() - spawn(TcpNode(host, 9090), classOf[Counter].getName()) - - receive { - case p: Process => - // communicate with counter - Console.println("" + node + ": Sending Incr() to remote Counter (" + p + ")...") - p ! Incr() - p ! Incr() - p ! Value(self) - receive { - case Result(v) => - Console.println("Received result: " + v) - } - } - } -} - -object CounterTest { - def main(args: Array[String]): unit = { - val serv = new TcpService(9090) - serv.start() - - val cu = new CounterUser - cu.start() - } -} |