CIO

Documentation

data CIO r

Concurrent IO. A composable monad of IO actions executable in a shared pool of threads.

Instances

Monad CIO

Functor CIO

Applicative CIO

MonadSTM CIO

MonadIO CIO

MonadCIO CIO

runCIO :: Int -> CIO r -> IO r

Run with a pool of the specified size.

runCIO' :: CIO r -> IO r

Run with a pool the size of the amount of available processors.

class Monad m => MonadCIO m where

Methods

getPoolNumCapabilities :: m Int

Get the maximum number of available threads, which is set in runCIO.

sequenceConcurrently :: [m a] -> m [a]

Same as Control.Monad.sequence, but performs concurrently.

sequenceConcurrently' :: [m a] -> m [a]

Same as sequenceConcurrently with a difference that it does not maintain the order of results, which allows it to execute a bit more efficiently.

sequenceConcurrently_ :: [m a] -> m ()

Same as Control.Monad.sequence_, but performs concurrently. Blocks the calling thread until all actions are finished.

Instances

MonadCIO CIO

MonadCIO m => MonadCIO (ReaderT r m)

(MonadCIO m, Monoid w) => MonadCIO (WriterT w m)

mapMConcurrently :: MonadCIO m => (a -> m b) -> [a] -> m [b]

mapMConcurrently' :: MonadCIO m => (a -> m b) -> [a] -> m [b]

mapMConcurrently_ :: MonadCIO m => (a -> m b) -> [a] -> m ()

forMConcurrently :: MonadCIO m => [a] -> (a -> m b) -> m [b]

forMConcurrently' :: MonadCIO m => [a] -> (a -> m b) -> m [b]

forMConcurrently_ :: MonadCIO m => [a] -> (a -> m b) -> m ()

distributeConcurrently :: MonadCIO m => m a -> m [a]

Run the provided side-effecting action on all available threads and collect the results. The order of results may vary from run to run.

distributeConcurrently_ :: MonadCIO m => m a -> m ()

Run the provided side-effecting action on all available threads.