diff options
Diffstat (limited to 'docs/examples/oneplacebuffer.scala')
-rw-r--r-- | docs/examples/oneplacebuffer.scala | 17 |
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) } } |