diff options
author | michelou <michelou@epfl.ch> | 2007-05-16 13:30:30 +0000 |
---|---|---|
committer | michelou <michelou@epfl.ch> | 2007-05-16 13:30:30 +0000 |
commit | 1f65685c9626929f3e6d7b81225f57fd4e68438c (patch) | |
tree | 54d3462ca86d36545ab6ef946a1095a0f15ac38f /docs/examples/boundedbuffer.scala | |
parent | 73b2db5db4fc7316467b51299994b47065bde74d (diff) | |
download | scala-1f65685c9626929f3e6d7b81225f57fd4e68438c.tar.gz scala-1f65685c9626929f3e6d7b81225f57fd4e68438c.tar.bz2 scala-1f65685c9626929f3e6d7b81225f57fd4e68438c.zip |
updated examples
Diffstat (limited to 'docs/examples/boundedbuffer.scala')
-rw-r--r-- | docs/examples/boundedbuffer.scala | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/docs/examples/boundedbuffer.scala b/docs/examples/boundedbuffer.scala index 414566adef..dceda62bd4 100644 --- a/docs/examples/boundedbuffer.scala +++ b/docs/examples/boundedbuffer.scala @@ -12,13 +12,13 @@ object boundedbuffer { def put(x: a) = synchronized { await (n < N) - elems(in) = x; in = (in + 1) % N; n = n + 1 + elems(in) = x; in = (in + 1) % 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 + val x = elems(out); out = (out + 1) % N ; n -= 1 if (n == N - 1) notifyAll() x } @@ -27,17 +27,17 @@ object boundedbuffer { def kill(delay: Int) = new java.util.Timer().schedule( new java.util.TimerTask { override def run() = { - Console.println("[killed]") + println("[killed]") System.exit(0) } }, delay) // in milliseconds - def main(args: Array[String]) = { + 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) = Console.println(ss) + def produceString = { cnt += 1; cnt.toString() } + def consumeString(ss: String) = println(ss) spawn { while (true) { val ssss = produceString; buf.put(ssss) } } spawn { while (true) { val s = buf.get; consumeString(s) } } kill(1000) |