From 96ae92e4f6f830a9a4e55768c3de0328a2a030ba Mon Sep 17 00:00:00 2001 From: michelou Date: Wed, 22 Feb 2006 17:54:31 +0000 Subject: adapted code to Scala 2 syntax in files src/exa... adapted code to Scala 2 syntax in files src/examples/**/*.scala --- docs/examples/oneplacebuffer.scala | 29 +++++++++++++++-------------- 1 file changed, 15 insertions(+), 14 deletions(-) (limited to 'docs/examples/oneplacebuffer.scala') diff --git a/docs/examples/oneplacebuffer.scala b/docs/examples/oneplacebuffer.scala index 7fa2ae8dba..2d6277913c 100644 --- a/docs/examples/oneplacebuffer.scala +++ b/docs/examples/oneplacebuffer.scala @@ -1,45 +1,46 @@ -package examples; +package examples object oneplacebuffer { import scala.concurrent._; class OnePlaceBuffer { - private val m = new MailBox() {}; // An internal mailbox - private case class Empty(), Full(x: Int); // Types of messages we deal with + private val m = new MailBox() {} // An internal mailbox + private case class Empty() // Types of messages we deal with + private case class Full(x: Int) - m send Empty(); // Initialization + m send Empty() // Initialization def write(x: Int): Unit = m receive { case Empty() => - Console.println("put " + x); + Console.println("put " + x) m send Full(x) } def read: Int = m receive { case Full(x) => - Console.println("get " + x); - m send Empty() ; x + Console.println("get " + x) + m send Empty(); x } } def main(args: Array[String]) = { - val buf = new OnePlaceBuffer; - val random = new java.util.Random(); + val buf = new OnePlaceBuffer + val random = new java.util.Random() def producer(n: int): unit = { - Thread.sleep(random.nextInt(1000)); - buf.write(n); + Thread.sleep(random.nextInt(1000)) + buf.write(n) producer(n + 1) } def consumer: unit = { - Thread.sleep(random.nextInt(1000)); - val n = buf.read; + Thread.sleep(random.nextInt(1000)) + val n = buf.read consumer } - ops.spawn(producer(0)); + ops.spawn(producer(0)) ops.spawn(consumer) } -- cgit v1.2.3