1

在 twitter 发布的文档《Effective Scala》中,我看到了一个代码示例:

class Pool(conns: Seq[Conn]) {
  private[this] val waiters = new Broker[Conn]
  private[this] val returnConn = new Broker[Conn]

  val get: Offer[Conn] = waiters.recv
  def put(c: Conn) { returnConn ! c }

  private[this] def loop(connq: Queue[Conn]) {
    Offer.choose(
      if (connq.isEmpty) Offer.never else {
        val (head, rest) = connq.dequeue
        waiters.send(head) { _ => loop(rest) }
      },
      returnConn.recv { c => loop(connq enqueue c) }
    ).sync()
  }

  loop(Queue.empty ++ conns)
}

该代码似乎不是尾递归的,也没有这样注释。由于这是一个连接池,可能会在程序的整个生命周期内一直运行,那么如何防止这样的池最终炸毁堆栈并生成 StackOverflowException 呢?

4

1 回答 1

6

代码根本不是递归的!loop不调用自己。它传递闭包{ _ => loop(rest) }和分别{ c => loop(connq enqueue c) }再次调用。没有递归,因此没有堆栈溢出。waiters.sendreturnConn.recvloop

于 2012-09-14T08:02:13.267 回答