Modulenetwork-mux-0.11.0.0Haskell2010

Control.Concurrent.JobPool

This module allows the management of a multiple Async jobs which are grouped by an 'Ord group => group' type.

Synopsis

datadata JobPool group (m :: Type -> Type) a

JobPool allows to submit asynchronous jobs, wait for their completion or cancel. Jobs are grouped, each group can be cancelled separately.

datadata Job group (m :: Type -> Type) a

An asynchronous job which belongs to some group and its exception handler.

valuewithJobPool

valueforkJob

Fork a Job using async.

valueforkJobOn

Fork a Job using asyncOn.

valuereadSize :: MonadSTM m => JobPool group m a -> STM m Int

valuereadGroupSize

valuewaitForJob :: MonadSTM m => JobPool group m a -> STM m a

Wait for next successfully completed job. Unlike wait it will not throw if a job errors.

valuecancelGroup

Cancel all threads in a given group. Blocks until all threads terminated.