jboner · March 27, 2019 16:43 · Apr 5, 2014 · Apr 5, 2014
diff --git a/GameOfPingPong.scala b/GameOfPingPong.scala
@@ -12,7 +12,7 @@ object PingPong extends App {
       case Ball =>
         counter += 1
         println(s"Ping counter: ${counter}")
-        Thread.sleep(1000)
+        Thread.sleep(1000) // you should *never* call Thread.sleep in a real application, just here to slow things down
         sender ! Ball
     }
   }

diff --git a/GameOfPingPong.scala b/GameOfPingPong.scala
@@ -0,0 +1,38 @@
+package demo
+
+import akka.actor.{Actor, Props, ActorSystem}
+
+object PingPong extends App {
+  case object Ball
+
+  class Ping extends Actor {
+    var counter = 0
+
+    def receive = {
+      case Ball =>
+        counter += 1
+        println(s"Ping counter: ${counter}")
+        Thread.sleep(1000)
+        sender ! Ball
+    }
+  }
+
+  class Pong extends Actor {
+    var counter = 0
+
+    def receive = {
+      case Ball =>
+        counter += 1
+        println(s"Pong counter: ${counter}")
+        Thread.sleep(1000)
+        sender ! Ball
+    }
+  }
+
+  val system = ActorSystem("pingpong")
+
+  val ping = system.actorOf(Props(classOf[Ping]), "ping")
+  val pong = system.actorOf(Props(classOf[Pong]), "pong")
+
+  ping.tell(Ball, pong)
+}