Control.Concurrent.Async.Extra

concurrent mapping

mapConcurrentlyBounded :: Traversable t => Int -> (a -> IO b) -> t a -> IO (t b)

Span a green thread for each task, but only execute N tasks concurrently.

mapConcurrentlyBounded_ :: Traversable t => Int -> (a -> IO ()) -> t a -> IO ()

Span a green thread for each task, but only execute N tasks concurrently. Ignore the result

mapConcurrentlyBatched :: (NFData b, Foldable t) => Int -> ([[b]] -> IO r) -> (a -> IO b) -> t a -> IO r

Span green threads to perform N (batch size) tasks in one thread and merge results using provided merge function

mapConcurrentlyBatched_ :: Foldable t => Int -> (a -> IO ()) -> t a -> IO ()

Span green threads to perform N (batch size) tasks in one thread and ignore results

mapConcurrentlyChunks :: (NFData b, Foldable t) => Int -> ([[b]] -> IO r) -> (a -> IO b) -> t a -> IO r

Split input into N chunks with equal length and work on each chunk in a dedicated green thread. Then merge results using provided merge function

mapConcurrentlyChunks_ :: Foldable t => Int -> (a -> IO ()) -> t a -> IO ()

Split input into N chunks with equal length and work on each chunk in a dedicated green thread. Ignore results

merge strategies

mergeConcatAll :: [[a]] -> [a]

Merge all chunks by combining to one list. (Equiv to join)