0

メッセージを処理するときに、別のアクターにメッセージを送信し、そのアクターが応答するのを待ち、応答されたメッセージを消費してから、次のように続行することは可能ですか?

val lineMap=HashMap[String,Int]()
receive {
   case bigTaskMap=> 
       for (line <-readSomeFile){
          if(lineMap.get(line)==None){
              anotherActor!line  // that actor will reply a hashmap which contain the key for line
              receive {
                 case x:HashMap => lineMap=x
              }     
          }
          lineMap.get(line) // use that value to do further work
       }
}
4

1 に答える 1