diff options
author | michelou <michelou@epfl.ch> | 2007-07-18 15:14:14 +0000 |
---|---|---|
committer | michelou <michelou@epfl.ch> | 2007-07-18 15:14:14 +0000 |
commit | 14ea3ab51e7a7712afd4aa94ecbe0d6799f5e4d9 (patch) | |
tree | 2d7961c93657ca766212dceb3091fe7122283732 /docs | |
parent | 3d8003db990beea3fe1c5dc678cd511e6df5d033 (diff) | |
download | scala-14ea3ab51e7a7712afd4aa94ecbe0d6799f5e4d9.tar.gz scala-14ea3ab51e7a7712afd4aa94ecbe0d6799f5e4d9.tar.bz2 scala-14ea3ab51e7a7712afd4aa94ecbe0d6799f5e4d9.zip |
updated example
Diffstat (limited to 'docs')
-rw-r--r-- | docs/examples/oneplacebuffer.scala | 20 |
1 files changed, 11 insertions, 9 deletions
diff --git a/docs/examples/oneplacebuffer.scala b/docs/examples/oneplacebuffer.scala index 55d85068ad..02b8a9cec6 100644 --- a/docs/examples/oneplacebuffer.scala +++ b/docs/examples/oneplacebuffer.scala @@ -2,7 +2,7 @@ package examples object oneplacebuffer { - import scala.concurrent._ + import scala.concurrent.{MailBox, ops} class OnePlaceBuffer { private val m = new MailBox() {} // An internal mailbox @@ -11,15 +11,17 @@ object oneplacebuffer { m send Empty() // Initialization - def write(x: Int): Unit = m receive { - case Empty() => - Console.println("put " + x) - m send Full(x) + def write(x: Int) { + m receive { + case Empty() => + println("put " + x) + m send Full(x) + } } def read: Int = m receive { case Full(x) => - Console.println("get " + x) + println("get " + x) m send Empty(); x } } @@ -27,8 +29,8 @@ object oneplacebuffer { def kill(delay: Int) = new java.util.Timer().schedule( new java.util.TimerTask { override def run() = { - Console.println("[killed]") - System.exit(0) + println("[killed]") + exit(0) } }, delay) // in milliseconds @@ -37,7 +39,7 @@ object oneplacebuffer { val buf = new OnePlaceBuffer val random = new java.util.Random() - def producer(n: int) { + def producer(n: Int) { Thread.sleep(random.nextInt(1000)) buf.write(n) producer(n + 1) |