scala - 如何与ZIO并行优雅地执行多种效果

Question

我知道我可以用

import zio.Task

def zip3Par[A, B, C](a: Task[A], b: Task[B], c: Task[C]): Task[(A, B, C)] =
  a.zipPar(b).zipWithPar(c) { case ((a, b), c) => (a, b, c) }

def zip4Par[A, B, C, D](a: Task[A], b: Task[B], c: Task[C], d: Task[D]): Task[(A, B, C, D)] =
  zip3Par(a, b, c).zipWithPar(d) { case ((a, b, c), d) => (a, b, c, d) }

并行执行3或4个任务，但是如果有更好的解决方案，我会更受伤吗？

Answer 1

您可以只将ZIO.collectAllPar与任务列表一起使用:

def collectTasks(tasks: Task[Int]*):Task[List[Int]] = ZIO.collectAllPar(tasks)

然后，您可以像这样使用它:

val t1 = Task.effect{
  Thread.sleep(100)
  println("t1 started")
  Thread.sleep(1000)
  1
}

val t2 = Task.effect{
  println("t2 started")
  Thread.sleep(1000)
  2
}


val t3 = Task.effect{
  println("t3 started")
  Thread.sleep(1000)
  3
}

(new DefaultRuntime() {}).unsafeRun(collectTasks(t1,t2,t3))

它将同时运行您的所有任务。

如果没有整形，那么在Scala 2中很难使用元组而不是列表来实现通用解决方案。它会在Scala 3中发生变化，因为那样的话它们可以作为异构列表来处理。