Data.Array.Parallel.Unlifted.Distributed.Primitive.DistST

Distributed ST computations.

Computations of type DistST are data-parallel computations which are run on each thread of a gang. At the moment, they can only access the element of a (possibly mutable) distributed value owned by the current thread.

TODO: Add facilities for implementing parallel scans etc.

TODO:

Documentation

data DistST s a

Data-parallel computations. When applied to a thread gang, the computation implicitly knows the index of the thread it's working on. Alternatively, if we know the thread index then we can make a regular ST computation.

Instances

Monad (DistST s)

Primitives.

stToDistST :: ST s a -> DistST s a

Lifts an ST computation into the DistST monad. The lifted computation should be data parallel.

distST_ :: Comp -> Gang -> DistST s () -> ST s ()

Execute a data-parallel computation on a Gang. The same DistST comutation runs on each thread.

distST :: DT a => Comp -> Gang -> DistST s a -> ST s (Dist a)

Execute a data-parallel computation, yielding the distributed result.

runDistST :: DT a => Comp -> Gang -> (forall s. DistST s a) -> Dist a

Run a data-parallel computation, yielding the distributed result.

runDistST_seq :: forall a. DT a => Gang -> (forall s. DistST s a) -> Dist a

myIndex :: DistST s Int

Yields the index of the current thread within its gang.

myD :: DT a => Dist a -> DistST s a

Yields the Dist element owned by the current thread.

readMyMD :: DT a => MDist a s -> DistST s a

Yields the MDist element owned by the current thread.

writeMyMD :: DT a => MDist a s -> a -> DistST s ()

Writes the MDist element owned by the current thread.

Monadic combinators

mapDST_ :: DT a => What -> Gang -> (a -> DistST s ()) -> Dist a -> ST s ()

mapDST :: (DT a, DT b) => What -> Gang -> (a -> DistST s b) -> Dist a -> ST s (Dist b)

zipWithDST_ :: (DT a, DT b) => What -> Gang -> (a -> b -> DistST s ()) -> Dist a -> Dist b -> ST s ()

zipWithDST :: (DT a, DT b, DT c) => What -> Gang -> (a -> b -> DistST s c) -> Dist a -> Dist b -> ST s (Dist c)