如何并行运行Scalaz任务

Question

我有一大堆Scalaz任务。创建方式如下：

val tasks = for (i <- 1 to 50) yield {
  Task.delay({
    Thread.sleep(100L)
    println(i)
    i
  })
}

val r = Nondeterminism[Task].gatherUnordered(tasks).run
println(r.mkString(" "))

我希望这些任务并行运行。以随机顺序打印数字，不要花5秒钟（每个任务有50个任务和100毫升睡眠）。

但是，很明显，每个任务需要100毫秒，所有任务都需要5秒钟，并且创建的列表是有序的。

如何并行运行它们？任务在哪里运行线程？

Answer 1

Task.delay暂停对其参数的求值，但它没有说明求值将发生在何处。您需要Task.apply，它具有相同的签名，只是它接受一个隐式ExecutorService，该服务将决定在哪个线程中进行求值：

import scalaz.Nondeterminism, scalaz.concurrent.Task

val tasks = for (i <- 1 to 50) yield {
  Task {
    Thread.sleep(100L)
    println(i)
    i
  }
}

val r = Nondeterminism[Task].gatherUnordered(tasks).run
println(r.mkString(" "))

这将使用默认的ExecutorService，它包装一个固定的线程池。如果您想要不同的策略，您可以将不同的ExecutorService放入隐式范围，或者在第二个参数列表中显式地为Task.apply提供一个。