summaryrefslogtreecommitdiff
path: root/docs/examples/boundedbuffer.scala
diff options
context:
space:
mode:
Diffstat (limited to 'docs/examples/boundedbuffer.scala')
-rw-r--r--docs/examples/boundedbuffer.scala12
1 files changed, 11 insertions, 1 deletions
diff --git a/docs/examples/boundedbuffer.scala b/docs/examples/boundedbuffer.scala
index 89ad811c65..f7aa26036e 100644
--- a/docs/examples/boundedbuffer.scala
+++ b/docs/examples/boundedbuffer.scala
@@ -24,13 +24,23 @@ object boundedbuffer {
}
}
+ def kill(delay: Int) = new java.util.Timer().schedule(
+ new java.util.TimerTask {
+ override def run() = {
+ Console.println("[killed]")
+ System.exit(0)
+ }
+ },
+ delay) // in milliseconds
+
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);
+ def consumeString(ss: String) = Console.println(ss)
spawn { while (true) { val ssss = produceString; buf.put(ssss) } }
spawn { while (true) { val s = buf.get; consumeString(s) } }
+ kill(5000)
}
}