Как я * предположил * использовать scala.collection.immutable.Queue?

У меня есть то, что я считаю самым распространенным случаем для обработки очереди. Я буду читать фронт очереди, действовать на элемент (который может привести к добавлению большего количества элементов в очередь), а затем цикл до тех пор, пока очередь не будет пуста.

Мой первый инстинкт был foreach, но нет, видимо, очередь (даже измененная) строгая, а foreach - петли над всеми элементами, находящимися в очереди, когда начинается итерация.
Я не могу понять синтаксис цикла while.

Вы думаете, что это будет что-то вроде

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

будет работать, за исключением того, что я обновляю q. Это работает:

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

но человек, это выглядит неправильно...

Ответ 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 -м шаге, вы удаляете что-то и, если необходимо, создаете новую очередь, возвращая это для следующего шага.

Все, что у вас осталось, - это условие остановки (не пустое), а затем, поскольку это просто определяет процесс, а не действительное действие, вы должны его запустить (например, с помощью no-op foreach).

Ответ 2

В то время как 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)

Ответ 3

Обработка a Queue в цикле while может быть выполнена без дубликата var/val следующим образом:

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

(Я знаю, что этот ответ задерживается на 7 лет, но тем не менее я считаю его ценной альтернативой.)