summaryrefslogtreecommitdiff
path: root/docs/examples/computeserver.scala
diff options
context:
space:
mode:
authormichelou <michelou@epfl.ch>2011-11-23 18:26:50 +0000
committermichelou <michelou@epfl.ch>2011-11-23 18:26:50 +0000
commit4213eb4d56c51311bcd2ccaa9710897aaef974de (patch)
treec431f982ecbf80bb54670e3294b752b1e4043bcb /docs/examples/computeserver.scala
parent667227b796fb2601363b6b7c0763b0e739a0edb2 (diff)
downloadscala-4213eb4d56c51311bcd2ccaa9710897aaef974de.tar.gz
scala-4213eb4d56c51311bcd2ccaa9710897aaef974de.tar.bz2
scala-4213eb4d56c51311bcd2ccaa9710897aaef974de.zip
updated some code examples
Diffstat (limited to 'docs/examples/computeserver.scala')
-rw-r--r--docs/examples/computeserver.scala9
1 files changed, 5 insertions, 4 deletions
diff --git a/docs/examples/computeserver.scala b/docs/examples/computeserver.scala
index bd6f536dfa..788be284d1 100644
--- a/docs/examples/computeserver.scala
+++ b/docs/examples/computeserver.scala
@@ -12,7 +12,7 @@ class ComputeServer(n: Int) {
private val openJobs = new Channel[Job]()
- private def processor(i: Int): Unit = {
+ private def processor(i: Int) {
while (true) {
val job = openJobs.read
println("read a job")
@@ -32,16 +32,17 @@ class ComputeServer(n: Int) {
() => reply.get
}
- spawn(replicate(0, n) { processor })
+ //spawn(replicate(0, n) { processor })
+ spawn((0 until n).par foreach { processor })
}
-object computeserver extends Application {
+object computeserver extends App {
def kill(delay: Int) = new java.util.Timer().schedule(
new java.util.TimerTask {
override def run() = {
println("[killed]")
- System.exit(0)
+ sys exit 0
}
},
delay) // in milliseconds