Scala 在没有 var 的情况下维持 Actor 的状态

Question

在另一种语言中，我有一些东西用新的状态来维护它，但我不知道如何用 scala actor 来做到这一点。我的设想是这样的：

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

还有另外两种方法可以在不使用变量的情况下在参与者中存储状态。如果您只需要向前传递状态，则可以让 Actor 向自身发送消息：

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
  }
}

或者，如果您需要保存在其他消息期间可访问的状态，则可以创建另一个 Actor；无论谁给你打电话，都需要了解新演员的情况：

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
  }
}

就我个人而言，我认为这样做很愚蠢。这是非常低效的（必须创建一个新的 Actor，并在状态发生变化时处理一个旧的 Actor，而 Actor 并不是那么轻量级！），而且它使代码变得非常复杂。在大多数情况下，将可变状态安全地隐藏为 Actor 中的 private[this] var 更为实用，这样您就知道只有 Actor 本身可以更改其可变状态。或者，您可以不使用新的参与者进行回复，而是使用调用者应该传回的状态信息进行回复，但这稍微不太安全，因为原则上他们可以修改状态信息，而不仅仅是再次将其传回。