monad-par- A library for parallel programming based on a monad

Safe HaskellNone



This is the scheduler described in the paper A Monad for Deterministic Parallelism. It is based on a lazy Trace data structure that separates the scheduler from the Par monad method implementations.



runPar :: Par a -> aSource

runParIO :: Par a -> IO aSource

A version that avoids an internal unsafePerformIO for calling contexts that are already in the IO monad.

fork :: Par () -> Par ()Source

new :: Par (IVar a)Source

creates a new IVar

newFull :: NFData a => a -> Par (IVar a)Source

creates a new IVar that contains a value

newFull_ :: a -> Par (IVar a)Source

creates a new IVar that contains a value (head-strict only)

get :: IVar a -> Par aSource

read the value in a IVar. The get can only return when the value has been written by a prior or parallel put to the same IVar.

put :: NFData a => IVar a -> a -> Par ()Source

put a value into a IVar. Multiple puts to the same IVar are not allowed, and result in a runtime error.

put fully evaluates its argument, which therefore must be an instance of NFData. The idea is that this forces the work to happen when we expect it, rather than being passed to the consumer of the IVar and performed later, which often results in less parallelism than expected.

Sometimes partial strictness is more appropriate: see put_.

put_ :: IVar a -> a -> Par ()Source

like put, but only head-strict rather than fully-strict.

spawn :: NFData a => Par a -> Par (IVar a)Source

spawn_ :: Par a -> Par (IVar a)Source

spawnP :: NFData a => a -> Par (IVar a)Source