network-mux-0.1.0.1: Multiplexing library
Safe Haskell None
Language Haskell2010

Control.Concurrent.JobPool

Documentation

data JobPool group m a Source #

data Job group m a Source #

Constructors

Job (m a) ( SomeException -> m a) group String

withJobPool :: forall group m a b. ( MonadAsync m, MonadThrow m, MonadLabelledSTM m) => ( JobPool group m a -> m b) -> m b Source #

forkJob :: forall group m a. ( MonadAsync m, MonadMask m, Ord group) => JobPool group m a -> Job group m a -> m () Source #

readSize :: MonadSTM m => JobPool group m a -> STM m Int Source #

readGroupSize :: ( MonadSTM m, Eq group) => JobPool group m a -> group -> STM m Int Source #

collect :: MonadSTM m => JobPool group m a -> STM m a Source #

cancelGroup :: ( MonadAsync m, Eq group) => JobPool group m a -> group -> m () Source #