diff options
Diffstat (limited to 'docs/examples/boundedbuffer.scala')
-rw-r--r-- | docs/examples/boundedbuffer.scala | 36 |
1 files changed, 36 insertions, 0 deletions
diff --git a/docs/examples/boundedbuffer.scala b/docs/examples/boundedbuffer.scala new file mode 100644 index 0000000000..983a3a7bf5 --- /dev/null +++ b/docs/examples/boundedbuffer.scala @@ -0,0 +1,36 @@ +package examples; + +object boundedbuffer { + + import concurrent.ops._; + + class BoundedBuffer[a](N: Int) { + var in, out, n = 0; + val elems = new Array[a](N); + + def await(cond: => Boolean) = while (!cond) { wait() } + + def put(x: a) = synchronized { + await (n < N); + elems(in) = x; in = (in + 1) % N; n = n + 1; + if (n == 1) notifyAll(); + } + + def get: a = synchronized { + await (n != 0); + val x = elems(out); out = (out + 1) % N ; n = n - 1; + if (n == N - 1) notifyAll(); + x + } + } + + def main(args: Array[String]) = { + val buf = new BoundedBuffer[String](10); + var cnt = 0; + def produceString = { cnt = cnt + 1; cnt.toString() } + def consumeString(ss: String) = System.out.println(ss); + spawn { while (true) { val ssss = produceString; buf.put(ssss) } } + spawn { while (true) { val s = buf.get; consumeString(s) } } + } + +} |