summaryrefslogtreecommitdiff
path: root/docs
diff options
context:
space:
mode:
authormichelou <michelou@epfl.ch>2007-07-18 15:14:14 +0000
committermichelou <michelou@epfl.ch>2007-07-18 15:14:14 +0000
commit14ea3ab51e7a7712afd4aa94ecbe0d6799f5e4d9 (patch)
tree2d7961c93657ca766212dceb3091fe7122283732 /docs
parent3d8003db990beea3fe1c5dc678cd511e6df5d033 (diff)
downloadscala-14ea3ab51e7a7712afd4aa94ecbe0d6799f5e4d9.tar.gz
scala-14ea3ab51e7a7712afd4aa94ecbe0d6799f5e4d9.tar.bz2
scala-14ea3ab51e7a7712afd4aa94ecbe0d6799f5e4d9.zip
updated example
Diffstat (limited to 'docs')
-rw-r--r--docs/examples/oneplacebuffer.scala20
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)