Codebase list ohcount / d62f219c-a984-415f-b69c-f521b00b8f15/main test / src_dir / scala1.scala
d62f219c-a984-415f-b69c-f521b00b8f15/main

Tree @d62f219c-a984-415f-b69c-f521b00b8f15/main (Download .tar.gz)

scala1.scala @d62f219c-a984-415f-b69c-f521b00b8f15/main — raw · history · blame 

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
import scala.actors.Actor

case object Ping
case object Pong
case object Stop

/**
 * Ping class
 */
class Ping(count: int, pong: Actor) extends Actor {
  def act() {
    var pingsLeft = count - 1
    pong ! Ping
    while (true) {
      receive {
        case Pong =>
          if (pingsLeft % 1000 == 0)
            Console.println("Ping: pong")
          if (pingsLeft > 0) {
            pong ! Ping
            pingsLeft -= 1
          } else {
            Console.println("Ping: stop")
            pong ! Stop
            exit()
          }
      }
    }
  }
}

/**
 * Pong class
 */
class Pong extends Actor {
  def act() {
    var pongCount = 0
    while (true) {
      receive {
        //pong back the ping
        case Ping =>
          if (pongCount % 1000 == 0)
            Console.println("Pong: ping "+pongCount)
          sender ! Pong
          pongCount = pongCount + 1
        //stop ping ponging
        case Stop =>
          Console.println("Pong: stop")
          exit()
      }
    }
  }
}

/*
 * And this is the main application, playing a game of ping pong
 */
object PingPong extends Application {
  val pong = new Pong
  val ping = new Ping(100000, pong)
  ping.start
  pong.start
}