Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import akka.actor._
- case class SetPartner(partner: ActorRef)
- case class Ball(counter: Int)
- class Player extends Actor {
- var partner = context.self
- def receive = {
- case SetPartner(p: ActorRef, m: Int) =>
- partner = p
- case Ball(counter) =>
- if(counter<=0)
- system.shutdown
- else if (counter%2==0) {
- println("Pong")
- partner ! Ball(counter-1)
- } else {
- println ("Ping")
- partner ! Ball(counter-1)
- }
- }
- }
- object Main {
- def main(args: Array[String]) {
- val system = ActorSystem("PingPong")
- val player1 = system.actorOf(Props[Player])
- val player2 = system.actorOf(Props[Player])
- player1 ! Set(player2)
- player2 ! Set(player1)
- player1 ! Ball(0)
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement