diff options
author | michelou <michelou@epfl.ch> | 2011-11-23 18:26:50 +0000 |
---|---|---|
committer | michelou <michelou@epfl.ch> | 2011-11-23 18:26:50 +0000 |
commit | 4213eb4d56c51311bcd2ccaa9710897aaef974de (patch) | |
tree | c431f982ecbf80bb54670e3294b752b1e4043bcb /docs/examples/computeserver.scala | |
parent | 667227b796fb2601363b6b7c0763b0e739a0edb2 (diff) | |
download | scala-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.scala | 9 |
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 |