アクターが発信者にメッセージを送り返す方法を教えてください。

Question

私はこれを再現しようとしていますexample。 すべてはコンパイルが、私はそれを実行すると、すべての私の結果は次のようになります。ここでは

scala> NameResolver ! ("www.scala-lang.org", self) 

    scala> self.receiveWithin(0) { case x => x } 
    res0: Any = TIMEOUT // and not Some(www.scala-lang.org/128.178.154.102) 

    scala> NameResolver ! ("wwwwww.scala-lang.org", self) 

    scala> self.receiveWithin(0) { case x => x } 
    res1: Any = TIMEOUT // and not None 

は私の例です：

import scala.actors._ 
import scala.actors.Actor._ 

case class Plus(x: Int, y: Int) 

val concurrentCalculator = actor { 
    while(true) 
     receive { 
     case Plus(x, y) => println(x + y) 
     case (Plus(x, y), caller: Actor) => caller ! (x + y) 
     } 
} 

scala> concurrentCalculator ! Plus(2,3) 
5 

scala> concurrentCalculator ! (Plus(2,3), self) 

scala> self.receiveWithin(1000) { case x => x } 
res0: Any = TIMEOUT // WTF? 

なぜ私の代わりに有効な結果のTIMEOUTを取得していますか？

Answer 1

あなたがチェックできるため、ScalaのREPLが機能する方法にないコードブロック内の異なるコール、上selfリターン異なる値（すべての評価される式）別のクラスにコンパイルされています

コードの1つのブロックに

scala> self 
res3: scala.actors.Actor = scala.actors.ActorProxy@1bb0ff0 

scala> self 
res4: scala.actors.Actor = scala.actors.ActorProxy@46530 

それが明示的に俳優として宣言されていない場合でも、それは動作します：

scala> { 
    | concurrentCalculator ! (Plus(2,3), self) 
    | self.receiveWithin(1000) { case x => x } 
    | } 
res9: Any = 5 

Answer 2

ここでの問題は、呼び出し元コードがアクタではないため、concurrentCalculatorアクタの2番目のケースが一致しないことです。

ではなく、これを試してみてください、そして、あなたが期待するものを見る必要があります。

val me = actor { 
    concurrentCalculator ! (Plus(2,3), self); 
    self.receiveWithin(1000) { case x => println(x) } 
}