Cats-Effect技术问题：如何转换List[IO]至IO[List]及合并IO[Unit]列表

嘿，这两个都是Cats-Effect中处理IO集合的常见需求，我来给你一步步说明：

最直接的方式是使用sequence方法，它会按顺序执行列表里的每个IO操作，把所有结果收集起来，最终包装成一个IO[List[A]]。

举个具体的例子：

import cats.effect.IO
import cats.implicits._

// 先构造一个List[IO[Int]]
val ioList: List[IO[Int]] = List(IO(1), IO(2), IO(3))

// 转换为IO[List[Int]]
val listWrappedInIO: IO[List[Int]] = ioList.sequence

如果你希望这些IO操作并行执行（比如你的IO是独立的网络请求，并行能提升效率），可以用parSequence方法，它会在后台并行运行所有IO，最终返回的结果列表顺序和原列表一致：

val parallelListIO: IO[List[Int]] = ioList.parSequence

因为你的IO返回的是Unit，我们不需要收集结果，只需要确保所有IO都执行完成就行，这里有几种常用方式：

方式一：顺序执行所有IO #

用sequence_方法（注意末尾的下划线），它本质上是先执行sequence然后忽略结果，专门针对返回Unit的场景做了优化：

import cats.effect.IO
import cats.implicits._

// 构造一个IO[Unit]列表，比如你的URL请求集合
val urlFetchIOs: List[IO[Unit]] = List(
  IO(println("Fetching URL 1")),
  IO(println("Fetching URL 2"))
)

// 合并为单个顺序执行的IO[Unit]
val sequentialFetch: IO[Unit] = urlFetchIOs.sequence_

你也可以用foreach_来实现同样的效果，写法更直观：

val sequentialFetch2: IO[Unit] = urlFetchIOs.foreach_(identity)

方式二：并行执行所有IO #

如果你的URL请求之间没有依赖，并行执行能大大提升速度，这时候用parSequence_：

val parallelFetch: IO[Unit] = urlFetchIOs.parSequence_

额外提示：容错处理 #

如果某个URL请求失败，默认的sequence_/parSequence_会立即终止并抛出错误。如果你希望即使部分请求失败，其他请求仍能继续执行，可以先把每个IO转为IO[Either[Throwable, Unit]]，再合并：

val resilientFetch: IO[Unit] = urlFetchIOs.traverse(_.attempt).void

这样所有IO都会执行完毕，不管成功失败，最终返回IO[Unit]。

内容的提问来源于stack exchange，提问作者nam