blob: a7a1dacc9deb5c9dbab3b7b437983400bbea4a80 (
plain) (
tree)
|
|
/* The Computer Language Shootout
http://shootout.alioth.debian.org/
contributed by Isaac Gouy
*/
import scala.concurrent._
object message {
def main(args: Array[String]) = {
val n = Integer.parseInt(args(0))
val nActors = 500
val finalSum = n * nActors
case class Message(value: Int)
class Incrementor(next: Pid) extends Actor {
var sum = 0
override def run() = {
while (true) {
receive {
case Message(value) =>
val j = value + 1
if (null != next){
next ! Message(j)
} else {
sum = sum + j
if (sum >= finalSum){
Console.println(sum);
System.exit(0) // exit without cleaning up
}
}
}
}
}
def pid() = { this.start; this.self }
}
def actorChain(i: Int, a: Pid): Pid =
if (i > 0) actorChain(i-1, new Incrementor(a).pid ) else a
val firstActor = actorChain(nActors, null)
var i = n; while (i > 0){ firstActor ! Message(0); i = i-1 }
}
}
|