Advertisement
Guest User

Untitled

a guest
Jan 21st, 2017
83
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Scala 0.76 KB | None | 0 0
  1. import akka.actor._
  2.  
  3.  
  4.   case class SetPartner(partner: ActorRef)
  5.   case class Ball(volley: Int)
  6.  
  7.   class Player extends Actor {
  8.  
  9.     var partner = context.self
  10.  
  11.     def receive = {
  12.  
  13.       case SetPartner(p: ActorRef) =>
  14.         partner = p
  15.  
  16.       case Ball(volley) =>
  17.         Thread.sleep(500)
  18.  
  19.         if (volley <= 0) {
  20.           println("Game over")
  21.         } else {
  22.           println (self.path.name + ": " + volley)
  23.           partner ! Ball(volley-1)
  24.         }
  25.     }
  26.   }
  27.  
  28.   object hello extends App{
  29.     val system = ActorSystem("PingPongDemo")
  30.     val ping = system.actorOf(Props[Player], "Ping")
  31.     val pong = system.actorOf(Props[Player], "Pong")
  32.  
  33.     ping ! SetPartner(pong)
  34.     pong ! SetPartner(ping)
  35.  
  36.     pong ! Ball(10)
  37.   }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement