git.iko.soy/streamly
on fbfa2aa help sign in
streamly/examples/parallel-loops.hs
20 lines 590 B history raw
1import Control.Applicative ((<|>))
2import Control.Concurrent (myThreadId, threadDelay)
3import Control.Monad.IO.Class (liftIO)
4import System.IO (stdout, hSetBuffering, BufferMode(LineBuffering))
5import System.Random (randomIO)
6import Streamly
8main = runStreamT $ do
9 liftIO $ hSetBuffering stdout LineBuffering
10 x <- loop "A" <|> loop "B"
11 liftIO $ myThreadId >>= putStr . show
12 >> putStr " "
13 >> print x
15 where
17 loop name = do
18 liftIO $ threadDelay 1000000
19 rnd <- liftIO (randomIO :: IO Int)
20 return (name, rnd) <|> loop name