Control.CUtils.CPUMultiThreading

A module of concurrent higher order functions.

Documentation

data ExceptionList

For exceptions caused by caller code.

Constructors

ExceptionList [SomeException]

Instances

Show ExceptionList

Defined in Control.CUtils.CPUMultiThreading

Methods

showsPrec :: Int -> ExceptionList -> ShowS

show :: ExceptionList -> String

showList :: [ExceptionList] -> ShowS

Exception ExceptionList

Defined in Control.CUtils.CPUMultiThreading

Methods

toException :: ExceptionList -> SomeException

fromException :: SomeException -> Maybe ExceptionList

displayException :: ExceptionList -> String

data ConcException

For internal errors. If a procedure throws this, some threads it created may still be running. This exception type is provided out of an abundance of caution, in case you want to take precautions against the activities of threads that for whatever reason cannot be terminated. If thrown it is never among the exceptions listed inside an ExceptionList.

Constructors

ConcException

Instances

Show ConcException

Defined in Control.CUtils.CPUMultiThreading

Methods

showsPrec :: Int -> ConcException -> ShowS

show :: ConcException -> String

showList :: [ConcException] -> ShowS

Exception ConcException

Defined in Control.CUtils.CPUMultiThreading

Methods

toException :: ConcException -> SomeException

fromException :: SomeException -> Maybe ConcException

displayException :: ConcException -> String

type ConcurrentMethod t t2 = Over (Kleisli ((->) Int)) IO () t () t2

A type for methods that accept a list of tasks.

type ConcurrentMethodAdapter t t2 = Pool -> (Int -> ConcurrentMethod t t2) -> Int -> ConcurrentMethod t t2

A type for functions that transform a base method, taking a thread pool also.

module Control.CUtils.ThreadPool

simpleConc_ :: Foldable f => Pool -> f (IO ()) -> () -> IO ()

Run the collection of tasks in the specified thread pool. Each task does not necessarily get its own thread--a best effort is made to spread the load over all threads in the thread pool.

concurrent_ :: Pool -> Int -> ConcurrentMethod () t

This function implements some policy for simpleConc_. simpleConc_ makes the guarantee that the tasks given as an argument, map one-to-one to the tasks run on the thread pool. This guarantee is dropped for the function concurrent_, which allows more optimization.

In order to get the tasks, the integer argument n is accepted and the functional mnds is evaluated in the range 0 to n-1 inclusive.

throwToCallerAdapter_ :: Pool -> (t1 -> ConcurrentMethod () ()) -> t1 -> ConcurrentMethod () ()

An adapter which modifies the argument concurrent method, to implement an exception handling policy in which exceptions are collected in a list, which is thrown as an exception in the caller. This appropriates the exception handling behavior of old versions of this package.

toNewStyle :: ((Int -> IO t2) -> IO t) -> ConcurrentMethod t t2