summaryrefslogtreecommitdiff
path: root/docs/examples/oneplacebuffer.scala
diff options
context:
space:
mode:
Diffstat (limited to 'docs/examples/oneplacebuffer.scala')
-rw-r--r--docs/examples/oneplacebuffer.scala17
1 files changed, 10 insertions, 7 deletions
diff --git a/docs/examples/oneplacebuffer.scala b/docs/examples/oneplacebuffer.scala
index ecc9f1b2e2..ccdb0f8732 100644
--- a/docs/examples/oneplacebuffer.scala
+++ b/docs/examples/oneplacebuffer.scala
@@ -24,6 +24,15 @@ object oneplacebuffer {
}
}
+ 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 OnePlaceBuffer
val random = new java.util.Random()
@@ -40,15 +49,9 @@ object oneplacebuffer {
consumer
}
- def kill = new java.util.Timer().schedule(
- new java.util.TimerTask {
- override def run() = System.exit(0)
- },
- 10000) // delay in milliseconds
-
ops.spawn(producer(0))
ops.spawn(consumer)
- kill
+ kill(10000)
}
}