test/pending/shootout/prodcons.scala


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
64

/* The Computer Language Shootout 
   http://shootout.alioth.debian.org/
   contributed by Isaac Gouy (Scala novice)
*/

import concurrent.SyncVar;
import concurrent.ops._;

object prodcons {
   def main(args: Array[String]) = {
      val n = toPositiveInt(args);
      val buffer = new SharedBuffer();
      var p = 0;
      var c = 0;
      val cDone = new SyncVar[Boolean];

      spawn { 
         while(p<n) { p=p+1; buffer put(p); }
      }

      spawn { 
         var v: Int = _;
         while(c<n) { c=c+1; v = buffer.get; }
         cDone set true;
      }

      cDone.get;
      Console println(p + " " + c); 
   }


   private def toPositiveInt(s: Array[String]) = {
      val i = 
         try { Integer.parseInt(s(0)); } 
         catch { case _ => 1 }
      if (i>0) i; else 1;
   }
}


private class SharedBuffer() {
   var contents: Int = _;
   var available = false;

   def get = synchronized {
      while (available == false) wait();
      available = false;
         // Console println("\t" + "get " + contents);
      notifyAll();
      contents
   }

   def put(value: Int) = synchronized {
      while (available == true) wait();
      contents = value;
      available = true;
         // Console println("put " + value);
      notifyAll();
   }
}