次のScala + Akkaコードのパフォーマンス/並行性を向上させる機会は何ですか？

Question

私のScala 2.9 / Akka 2.0 RC2コードの並行性とパフォーマンスを向上させる機会を探しています。次のコードを考えると：

import akka.actor._

case class DataDelivery(data:Double)

class ComputeActor extends Actor {
    var buffer = scala.collection.mutable.ArrayBuffer[Double]()

    val functionsToCompute = List("f1","f2","f3","f4","f5")
    var functionMap = scala.collection.mutable.LinkedHashMap[String,(Map[String,Any]) => Double]()  
    functionMap += {"f1" -> f1}
    functionMap += {"f2" -> f2}
    functionMap += {"f3" -> f3}
    functionMap += {"f4" -> f4}
    functionMap += {"f5" -> f5}

    def updateData(data:Double):scala.collection.mutable.ArrayBuffer[Double] = {
        buffer += data
        buffer
    }

    def f1(map:Map[String,Any]):Double = {
//    println("hello from f1")
      0.0
    }

    def f2(map:Map[String,Any]):Double = {
//    println("hello from f2")
      0.0
    }

    def f3(map:Map[String,Any]):Double = {
//    println("hello from f3")
      0.0
    }

    def f4(map:Map[String,Any]):Double = {
//    println("hello from f4")
      0.0
    }

    def f5(map:Map[String,Any]):Double = {
//    println("hello from f5")
      0.0
    }

    def computeValues(immutableBuffer:IndexedSeq[Double]):Map[String,Double] = {
        var map = Map[String,Double]()
        try {
            functionsToCompute.foreach(function => {
                val value = functionMap(function)
                function match {
                    case "f1" =>
                        var v = value(Map("lookback"->10,"buffer"->immutableBuffer,"parm1"->0.0))
                        map += {function -> v}
                    case "f2" =>
                        var v = value(Map("lookback"->20,"buffer"->immutableBuffer))
                        map += {function -> v}
                    case "f3" =>
                        var v = value(Map("lookback"->30,"buffer"->immutableBuffer,"parm1"->1.0,"parm2"->false))
                        map += {function -> v}
                    case "f4" =>
                        var v = value(Map("lookback"->40,"buffer"->immutableBuffer))
                        map += {function -> v}
                    case "f5" =>
                        var v = value(Map("buffer"->immutableBuffer))
                        map += {function -> v}
                    case _ => 
                        println(this.unhandled())
                }
            })
        } catch {
            case ex: Exception =>
              ex.printStackTrace()
        }
        map
    }

    def receive = {
      case DataDelivery(data) =>
        val startTime = System.nanoTime()/1000
        val answers = computeValues(updateData(data))
        val endTime = System.nanoTime()/1000
        val elapsedTime = endTime - startTime
        println("elapsed time is " + elapsedTime)
        // reply or forward
      case msg =>
        println("msg is " + msg)
    }

}

object Test {
    def main(args:Array[String]) {
        val system = ActorSystem("actorSystem") 
        val computeActor = system.actorOf(Props(new ComputeActor),"computeActor")
        var i = 0
        while (i < 1000) {  
            computeActor ! DataDelivery(i.toDouble)
            i += 1
        }
    }
}

.

これを実行すると、出力（マイクロ秒に変換された）が

elapsed time is 4898
elapsed time is 184
elapsed time is 144
    .
    .
    .
elapsed time is 109
elapsed time is 103

.

JVMのインクリメンタルコンパイラを蹴り出しているのがわかります。

私は1つの迅速な勝利が変わるかもしれないと思いました

    functionsToCompute.foreach(function => {

.

    functionsToCompute.par.foreach(function => {

.

しかし、これは以下の経過時間をもたらす

elapsed time is 31689
elapsed time is 4874
elapsed time is 622
    .
    .
    .
elapsed time is 698
elapsed time is 2171

.

いくつかの情報：

1）2コアのMacBook Proでこれを実行しています。

2）フルバージョンでは、変換可能な共有バッファの一部をループする長い実行操作である。俳優のメールボックスからのメッセージを検索しているので、これは問題のようには見えませんが、疑似テーブルの増加に伴う問題になる可能性があると思います。これが私がIndexedSeqに変換された理由です。

3）フルバージョンでは、ファンクションストコムパータリストは異なる場合があるので、関数マップ内の全ての項目が必ずしも（すなわち）呼ばれるわけではない（すなわち）functionmap.sizeがfunctionStocompute.size よりはるかに大きい場合がある。

4）関数は並行して計算することができますが、結果として得られるマップはを返す前に完了する必要があります。

いくつかの質問：

1）パラレルバージョンをより速く実行するために何ができますか？

2）非遮断と遮断の先物を追加するのは理にかなっていますか？

3）他の俳優に計算を転送することを意味しますか？

4）不変性/安全性を高める機会は何ですか？

ありがとう、 ブルース

Answer 1

要求されたように例を提供する（遅延について申し訳ありませんが、そうではない通知がありません）。

AKKAドキュメント