Справедливая параллельная функция `map` в haskell?

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).

Answer 2

http://hackage.haskell.org/package/random-shuffle-0.0.2

broadcast a rs = do 
   g <- newStdGen
   mapM_ (send a) $ shuffle' rs (length rs) g