summaryrefslogtreecommitdiff
path: root/docs/examples/boundedbuffer.scala
diff options
context:
space:
mode:
authormichelou <michelou@epfl.ch>2007-05-16 13:30:30 +0000
committermichelou <michelou@epfl.ch>2007-05-16 13:30:30 +0000
commit1f65685c9626929f3e6d7b81225f57fd4e68438c (patch)
tree54d3462ca86d36545ab6ef946a1095a0f15ac38f /docs/examples/boundedbuffer.scala
parent73b2db5db4fc7316467b51299994b47065bde74d (diff)
downloadscala-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.scala12
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)