summaryrefslogtreecommitdiff
path: root/docs/examples/actors/counter.scala
diff options
context:
space:
mode:
Diffstat (limited to 'docs/examples/actors/counter.scala')
-rw-r--r--docs/examples/actors/counter.scala62
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()
- }
-}