Scala：如何在 map/foreach 迭代之间等待？

Question

我现在卡住了，答案可能在谷歌的某个地方，但我不知道这次该用什么词，所以我希望有人能在这里帮助我。

我有一个元素列表，我想对每个元素应用一个函数，但我想在每个元素之间等待。

我现在有类似的东西：

  val numbers = List(10, 11, 12,13,14)
  numbers.foreach(i => {
    //do some stuff with i
    Thread.sleep(1000)
  })

但我认为这不是正确的做法。也许有一种方法不会阻止一切？

Answer 1

在 JVM 上的普通 Scala 中，您可以使用 Java 的 ScheduledExecutorService:

val list: List[Int] = List(1,2,3)

private val es: ScheduledExecutorService = Executors.newScheduledThreadPool(1)

type ResultType = Unit

val futures: Seq[ScheduledFuture[ResultType]] = list.zipWithIndex.map { case (integer, index) =>
  val runnable: Callable[ResultType] = () => println(integer)
  es.schedule(runnable, index*1, duration.SECONDS)
}

其实有一个关于预定Scala Future的话题-Scala - ScheduledFuture

在this approach 的帮助下，您可以编写我上面介绍的相同逻辑：

val list: List[Int] = List(1,2,3)

type ResultType = Unit

val futures: Seq[Future[ResultType]] = list.zipWithIndex.map { case (integer, index) =>
  DelayedFuture(index * 1.seconds)(println(integer))
}