scala - 同时执行两个 fs2 任务（非确定性）

Question

使用 Scalaz Task，我可以使用scalaz.Nondeterminism.both：

Nondeterminism[Task]
 .both(
   Task.now("Hello"),
   Task.now("world")
 )

或与Nondeterminism[Task].gatherUnordered().

我怎样才能对fs2 0.9.x 版本的任务做同样的事情？

Answer 1

我假设您使用的是 fs2 版本 0.9.x。要并行执行多个任务，您只需调用Task.start. 这是文档中的一个示例：

for {
   f <- Task.start { expensiveTask1 }
   // at this point, `expensive1` is evaluating in background

   g <- Task.start { expensiveTask2 }
   // now both `expensiveTask2` and `expensiveTask1` are running

   result1 <- f
   // we have forced `f`, so now only `expensiveTask2` may be running

   result2 <- g
   // we have forced `g`, so now nothing is running and we have both results

 } yield (result1 + result2)

所以在你的情况下，它看起来像这样：

for {
  ta <- Task.start(Task.now("Hello"))
  tb <- Task.start(Task.now("World"))
  a <- ta
  b <- tb
} yield (a, b)

请注意，将来可能会用更少的样板来做这样的事情。有一个 PR 正在添加一个Parallel类型类，这将允许我们编写如下内容：

(taskA, taskB).parMapN((a, b) => ...)