From c09f6173e96ec741c9b38edfee969ae8c6b74d4e Mon Sep 17 00:00:00 2001 From: michelou Date: Wed, 17 Nov 2010 12:26:13 +0000 Subject: updates Scala examples, added detach plugin --- docs/examples/boundedbuffer.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'docs/examples/boundedbuffer.scala') diff --git a/docs/examples/boundedbuffer.scala b/docs/examples/boundedbuffer.scala index dceda62bd4..359bfd8d06 100644 --- a/docs/examples/boundedbuffer.scala +++ b/docs/examples/boundedbuffer.scala @@ -4,19 +4,19 @@ object boundedbuffer { import concurrent.ops._ - class BoundedBuffer[a](N: Int) { + class BoundedBuffer[A](N: Int)(implicit m: ClassManifest[A]) { var in, out, n = 0 - val elems = new Array[a](N) + val elems = new Array[A](N) def await(cond: => Boolean) = while (!cond) { wait() } - def put(x: a) = synchronized { + def put(x: A) = synchronized { await (n < N) elems(in) = x; in = (in + 1) % N; n += 1 if (n == 1) notifyAll() } - def get: a = synchronized { + def get: A = synchronized { await (n != 0) val x = elems(out); out = (out + 1) % N ; n -= 1 if (n == N - 1) notifyAll() -- cgit v1.2.3