summaryrefslogtreecommitdiff
path: root/docs/examples/boundedbuffer.scala
diff options
context:
space:
mode:
authormichelou <michelou@epfl.ch>2006-03-08 17:42:34 +0000
committermichelou <michelou@epfl.ch>2006-03-08 17:42:34 +0000
commitc36fefb5da67593eaf4d03a4d87dba49052e48c0 (patch)
tree5c3a834b5af3abe666da1c34be0a179371c64b66 /docs/examples/boundedbuffer.scala
parent3d41a873e2b40d56ec60cfca7fb2cb9cef71f7fb (diff)
downloadscala-c36fefb5da67593eaf4d03a4d87dba49052e48c0.tar.gz
scala-c36fefb5da67593eaf4d03a4d87dba49052e48c0.tar.bz2
scala-c36fefb5da67593eaf4d03a4d87dba49052e48c0.zip
added method 'kill' in some examples docs/examp...
added method 'kill' in some examples docs/examples/*.scala
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)
}
}