使用 Scala actor 和 receiveWithin 时出现 Stackoverflow 异常

Question

一段时间后，该演员填满了堆栈。可能的解决方案？

object Puller extends Actor {

 def act() = {
  receiveWithin(2000) {
    case Stop => println("stoping puller")
        exit()
    case Noop => println("nothing happens")
        act()
    case TIMEOUT => doPull
        act()
  }
}

  def doPull() = // stuff...
}

我很高兴在《Scala 编程》中找到这段代码。

Answer 1

您的 act 不是尾递归的。您可以按如下方式修改：

  @tailrec // in the presence of this annotation, the compiler will complain, if the code is not tail-recursive
  def act() = {
    receiveWithin(2000) {
      case Stop => println("stoping puller"); exit()
      case Noop => println("nothing happens")
      case TIMEOUT => doPull
    }
    act()
  }

Answer 2

嗯，它的堆栈溢出有非常明显的原因；它是递归的，但不是尾递归的。这里有两个选项：

要么：使用 while 循环：

def act() = 
  while(true) {
    receiveWithin(2000) {
      case Stop    => println("stoping puller"); exit()
      case Noop    => println("nothing happens")
      case TIMEOUT => doPull
    }
  }

或：使用 loop 和 react （其中有通过将参与者与占用单个线程分离来实现可扩展的额外好处）。

def act() = 
  loop {
    reactWithin(2000) {
      case Stop    => println("stoping puller"); exit()
      case Noop    => println("nothing happens")
      case TIMEOUT => doPull
    }
  }

如果此代码存在于Scala 编程中，那么它可能更多地意味着概念验证，而不是可行的生产代码。事实上，根据记忆，它继续解释了如何避免递归 act 调用。