diff options
| -rw-r--r-- | docs/examples/auction.scala | 12 | ||||
| -rw-r--r-- | docs/examples/boundedbuffer.scala | 12 | ||||
| -rw-r--r-- | docs/examples/computeserver.scala | 11 | ||||
| -rw-r--r-- | docs/examples/oneplacebuffer.scala | 17 | ||||
| -rw-r--r-- | docs/examples/parsers2.scala | 2 |
5 files changed, 44 insertions, 10 deletions
diff --git a/docs/examples/auction.scala b/docs/examples/auction.scala index 44f4318074..a7d5119aae 100644 --- a/docs/examples/auction.scala +++ b/docs/examples/auction.scala @@ -115,7 +115,7 @@ object auction { log("auctionConcluded") } case AuctionOver() => { - running = false; + running = false log("auctionOver") } } @@ -123,11 +123,21 @@ object auction { } } + 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]) = { seller.start() auction.start() client(1, 20, 200).start() client(2, 10, 300).start() + kill(20000) } } diff --git a/docs/examples/boundedbuffer.scala b/docs/examples/boundedbuffer.scala index 89ad811c65..f7aa26036e 100644 --- a/docs/examples/boundedbuffer.scala +++ b/docs/examples/boundedbuffer.scala @@ -24,13 +24,23 @@ object boundedbuffer { } } + 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 BoundedBuffer[String](10) var cnt = 0 def produceString = { cnt = cnt + 1; cnt.toString() } - def consumeString(ss: String) = System.out.println(ss); + def consumeString(ss: String) = Console.println(ss) spawn { while (true) { val ssss = produceString; buf.put(ssss) } } spawn { while (true) { val s = buf.get; consumeString(s) } } + kill(5000) } } diff --git a/docs/examples/computeserver.scala b/docs/examples/computeserver.scala index 96d7e6560a..50e2ed034f 100644 --- a/docs/examples/computeserver.scala +++ b/docs/examples/computeserver.scala @@ -36,7 +36,18 @@ class ComputeServer(n: Int) { } object computeserver extends Application { + + 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 + val server = new ComputeServer(1) val f = server.future(42) Console.println(f()) + kill(10000) } 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) } } diff --git a/docs/examples/parsers2.scala b/docs/examples/parsers2.scala index 2688b162ee..f15ca56e0a 100644 --- a/docs/examples/parsers2.scala +++ b/docs/examples/parsers2.scala @@ -3,7 +3,7 @@ package examples object parsers2 { abstract class Tree - case class Id (s: String) extends Tree + case class Id(s: String) extends Tree case class Num(n: int) extends Tree case class Lst(elems: List[Tree]) extends Tree |