异步映射中的同步部分

Question

我有一个大 IO 函数，它会不断地从文件夹中加载数据，对数据执行纯计算，然后将其写回。

我正在使用多个文件夹并行运行此功能

mapConcurrently_ iofun folderList

来自http://hackage.haskell.org/package/async-2.1.1.1/docs/Control-Concurrent-Async.html#v%3amapConcurrently

这很好用......但有点太好了。现在，即使putStrLn 调用的字符输出也是异步的，这会导致控制台日志无法读取。

有没有办法使 IO Actions 同步，甚至是 putStrLn 的同步版本更好？

Answer 1

如果你想使用 STM，你协调线程的方式是通过MVars 或TVars。您可以在“Parallel and Concurrent Haskell”中阅读所有关于它们的信息。你可以这样做：

do mutex <- newMVar ()
   let putStrLn' = withMVar mutex . const . putStrLn 
   mapConcurrently_ (iofunPrintingWith putStrLn') folderList