在 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 呢?