我“应该”如何使用 scala.collection.immutable.Queue？

Question

我认为处理队列的最常见情况是这样的。我将读取队列的前面，对元素进行操作（这可能会导致更多元素添加到队列中），然后循环直到队列为空。

1. 我的第一直觉是 foreach，但不是，显然队列（即使是可变队列）是严格的，并且 foreach 在迭代开始时循环遍历队列中的所有元素。
2. 我无法弄清楚 while 循环的语法。

您可能会认为这会起作用

while (!q.isEmpty) {
   var (e, q) = q.dequeue
   ... }

，只是我重新声明了 q。这确实有效：

while (!q.isEmpty) {
   var (e, q1) = q.dequeue
   q = q1
   ... }

但是伙计，它看起来错误吗？

Answer 1

这是完全避免任何变量的一种方法：

val q0 = collection.immutable.Queue("1","Two","iii")
Iterator.iterate(q0) { qi =>
  val (e,q) = qi.dequeue
  println("I just dequeued "+e)  // Your side-effecting operations go here
  if (e.length!=2) q.enqueue("..")  // Your changes to the queue go here
  else q
}.takeWhile(! _.isEmpty).foreach(identity)

从初始队列 q0 开始，然后在第 qi 步中，将某些内容出列并生成一个新队列，如果需要，将其返回以进行下一步。

您剩下的就是停止条件（不为空），然后由于这只是定义了一个进程，而不是实际操作，因此您必须运行它（例如，使用无操作 foreach）。

Answer 2

而Rex Kerr的答案很好，迭代器是可变的。这是一个真正不可变的解决方案，非常接近 Rex Kerr 自己的答案中的代码。

val q0 = collection.immutable.Queue("1","Two","iii")
@annotation.tailrec def processQueue(queue: collection.immutable.Queue[String]): Unit = if (queue.nonEmpty) {
    val (element, rest) = queue.dequeue
    println("I just dequeued "+element)
    if (element.length != 2) processQueue(rest.enqueue(".."))
    else processQueue(rest)
}
processQueue(q0)

Answer 3

在 while 循环中处理 Queue 可以在没有重复的 var/val 的情况下完成，如下所示：（

var q = Queue("foo", "bar", "baz")
while (q.nonEmpty) {
  val e = q.head
  q = q.tail
  // Do something with `e` here
}

---

我是意识到这个答案晚了 7 年，但我认为它仍然是一个有价值的选择。）