From d5da7d9aa5a8d4833775454853e81ead20cc37a7 Mon Sep 17 00:00:00 2001 From: Martin Odersky Date: Mon, 10 Mar 2003 11:55:36 +0000 Subject: *** empty log message *** --- sources/examples/boundedbuffer.scala | 30 ++++++++++++++++++++++++++++++ 1 file changed, 30 insertions(+) create mode 100644 sources/examples/boundedbuffer.scala (limited to 'sources/examples/boundedbuffer.scala') diff --git a/sources/examples/boundedbuffer.scala b/sources/examples/boundedbuffer.scala new file mode 100644 index 0000000000..f308d0d472 --- /dev/null +++ b/sources/examples/boundedbuffer.scala @@ -0,0 +1,30 @@ +package examples; + +import concurrent.ops._; + +class BoundedBuffer[a](N: Int) extends Monitor() with { + var in = 0, out = 0, n = 0; + val elems = new Array[a](N); + + 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 + } +} + +module test { + 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) } } +} \ No newline at end of file -- cgit v1.2.3