diff options
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) |