如何并行运行一组独立IO动作？求并发版sequenceA处理[IO a]

在Haskell中，你可以使用async库来实现类似sequenceA的并发执行效果，完全不需要锁这类同步机制——因为你的IO动作相互独立，没有共享可变状态。

核心工具：mapConcurrently #

mapConcurrently是async库中最直接替代sequenceA的函数，它的作用是并发遍历一个可遍历结构（比如列表）里的IO动作，等待所有动作完成后按原顺序返回结果。

它的类型签名为：

mapConcurrently :: Traversable t => (a -> IO b) -> t a -> IO (t b)

对于[IO a]类型的列表，你只需要传入id函数作为第一个参数，直接复用每个元素的IO动作：

示例代码 #

import Control.Concurrent.Async (mapConcurrently)

main :: IO ()
main = do
  -- 定义一组独立的IO动作
  let ioTasks = [
          putStrLn "执行任务1",
          putStrLn "执行任务2",
          return 42,
          readFile "example.txt"
        ]
  -- 并发执行所有任务，收集结果
  results <- mapConcurrently id ioTasks
  -- 输出结果（顺序和原列表一致）
  print results

其他实用函数 #

• mapConcurrently_：如果不需要收集执行结果，只需要并发完成所有IO动作，可以用这个函数，它的类型是Traversable t => (a -> IO b) -> t a -> IO ()，用法和mapConcurrently类似，只是丢弃结果。
• concurrently：专门用于并发执行两个IO动作，返回两者的结果元组，适合处理成对的独立任务。

注意事项 #

• async库会自动管理底层的线程创建和销毁，你不需要手动处理线程生命周期。
• 所有任务会同时启动，直到全部完成才会返回结果，和sequenceA的行为一致，只是执行方式从串行变成了并行。

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