斯卡拉保持狀態在沒有var的演員

Question

在另一種語言中，我有一些自己與新狀態調用來維護它，但我沒有看到如何與scala演員做到這一點。這樣的事情是我如何設想：

def act(state) 
    react { 
    case blah => act(doSomething(state, blah)) 
    } 
} 

Answer 1

好吧..有趣的事情。我稍微調整了一下我的問題，並發現它編譯。我意識到所發生的一切就是我必須返回一個部分函數。嗯，我可以返回已在那裏參數的部分功能，所以......

import scala.actors._ 

object MyActor extends Actor { 
    def proc(s: Int) { 
    react { 
     case input: String => 
     if ((s % 10000) == 0) { 
      println(s + ", " + input) 
     } 
     proc(s + 1) 
    } 
    } 

    def act = proc(0) 
} 

object TestActors { 
    def main(args: Array[String]): Unit = { 
    MyActor.start() 

    for (s <- 1 to 10000000) { 
     MyActor ! "a message" 
    } 
    } 
} 

的好處是多一點的調整，它可以很容易地一概而論。

Answer 2

還有兩種方法可以在不使用變量的情況下在演員中存儲狀態。如果你只需要直傳狀態，可以讓演員將消息發送到本身：

object MailsSelf { 
    import scala.actors._ 
    class Selfish extends Reactor[Any] { 
    def act() { loop { react { 
     case i: Int if (i>=0) => 
     println(i) 
     this ! (i-1) // Self-messaging instead of recursive call 
     case _ => exit 
    }}} 
    } 
    def main(args: Array[String]) { 
    (new Selfish).start() ! 5 
    } 
} 

另外，如果您需要保存狀態在其他消息是可訪問的，您可以創建另一個演員;誰打電話給你，然後需要通知新的演員：

object EndlessActors { 
    import scala.actors._ 
    class Delegater(n: Int) extends ReplyReactor { 
    def act() { loop { react { 
     case i: Int if (i*n >= 0) => 
     println(i*n) 
     val next = new Delegater(n-1) 
     next.start() 
     reply(Some(next)) 
     case _ => reply(None); exit 
    }}} 
    } 
    def main(args: Array[String]) { 
    val original = new Delegater(5) 
    original.start() 
    Iterator.iterate(Option(original)){ maybe => 
     maybe.flatMap(d => { 
     val result = (d !? 5) 
     result match { 
      case Some(d2: Delegater) => Some(d2) 
      case _ => None 
     } 
     }) 
    }.takeWhile(_.isDefined).foreach(_ => {}) // Foreach forces evaluation 
    } 
} 

我個人認爲這樣做是愚蠢的。這是非常低效的（一個新的演員必須被創建，並且一箇舊的演員會隨時改變狀態 - 而演員並不是輕量級的！），並且它實質上使代碼複雜化了。在大多數情況下，在演員中保持隱藏的可變狀態爲private[this] var更爲實用，以便您知道只有演員本身可以更改其可變狀態。另外，你可以不用新的actor來回答，而是用調用者應該返回的狀態信息來回答，但這樣做的安全性稍差，因爲他們原則上可以修改狀態信息而不是僅僅傳遞回來。