Utils.Parallel

Documentation

data TaskRunnerStrategy

Constructors

Persistent

Failing

Instances

Eq TaskRunnerStrategy

Show TaskRunnerStrategy

taskRunner :: TaskRunnerStrategy -> TVar Bool -> TVar [IO ()] -> IO ()

parRun :: TaskRunnerStrategy -> Int -> [IO ()] -> IO ()

parRunWithMonitor :: TaskRunnerStrategy -> Int -> (TVar [IO ()] -> [TVar Bool] -> IO ()) -> [IO ()] -> IO ()

fork1 :: (a -> IO b) -> a -> IO (MVar b)

fork :: (a -> IO b) -> [a] -> IO [MVar b]

joinMVars :: [MVar b] -> IO [b]

forkAndJoin :: (a -> IO b) -> [a] -> IO [b]