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 ∷ ∀ group m a b. (MonadAsync m, MonadThrow m, MonadLabelledSTM m) ⇒ (JobPool group m a → m b) → m b Source #

forkJob ∷ ∀ 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 #