haskell - haskell中公平并发 `map`函数？

Question

假设我正在模拟某种网络，并且有一个通过 Chans 列表广播值的函数:

broadcast :: a -> [Receiver] -> IO ()
broadcast a = mapM_ (send a)

这会将数据按顺序“发送”到每个接收器。我想改为不确定地向所有接收者广播。

感谢您提供任何线索。

Answer 1

仅使用 GHC 的并发性怎么样？

broadcast :: a -> [Receiver] -> IO ()
broadcast a = mapM_ (forkIO . send a)

然后确保使用线程 RTS(使用 ghc -threaded 编译)。