Documentation

data JobPool m a Source #

data Job m a Source #

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

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

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

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