并行执行 `IO` 的 `List`

Question

这是我们要并行执行 3 IO 的示例

def test: Unit = {
    val ioA = IO.shift *> IO(println("Running ioA"))
    // ioA: cats.effect.IO[Unit] = <function1>

    val ioB = IO.shift *> IO(println("Running ioB"))
    // ioB: cats.effect.IO[Unit] = <function1>

    val ioC = IO.shift *> IO(println("Running ioC"))
    // ioC: cats.effect.IO[Unit] = <function1>

    val program: IO[Unit] = (ioA, ioB, ioC).parMapN { (_, _, _) => () }
    // program: cats.effect.IO[Unit] = <function1>

    program.unsafeRunSync()
  }

第一个问题：如果在这个例子中使用IO.shift的意义是什么？

第二个问题：如果我们想要并行执行 List of IO 怎么办？我已经为这个任务创建了一个函数，但我不知道这个东西是否已经存在于库中

def parallelize(ios: List[IO[Unit]]): IO[Unit] = {
    ios.foldLeft(IO.pure(())) { case (currentResult, currentItem) =>
      (currentResult, currentItem).parMapN((_, _) => ())
    }
  }

Answer 1

这适用于 "cats-core:1.1.0" 和 "cats-effect:0.10.1"

import cats.instances.list._
import cats.syntax.parallel._

//ios: List[IO[A]]
ios.parSequence //IO[List[A]]

并行执行 `IO` 的 `List`

Execute a `List` of `IO` in parallel

scala

scala-cats