Data.Array.Parallel.Unlifted.Distributed.Primitive.DT

Distributable Types

class DT a where

Class of distributable types. Instances of DT can be distributed across all workers of a Gang. All such types must be hyperstrict as we do not want to pass thunks into distributed computations.

Associated Types

data Dist a

data MDist a :: * -> *

Methods

indexD :: String -> Dist a -> Int -> a

Extract a single element of an immutable distributed value.

newMD :: Gang -> ST s (MDist a s)

Create an unitialised distributed value for the given Gang. The gang is used (only) to know how many elements are needed in the distributed value.

readMD :: MDist a s -> Int -> ST s a

Extract an element from a mutable distributed value.

writeMD :: MDist a s -> Int -> a -> ST s ()

Write an element of a mutable distributed value.

unsafeFreezeMD :: MDist a s -> ST s (Dist a)

Unsafely freeze a mutable distributed value.

deepSeqD :: a -> b -> b

Ensure a distributed value is fully evaluated.

sizeD :: Dist a -> Int

Number of elements in the distributed value.

• For debugging only, as code shouldn't be sensitive to the return value.

sizeMD :: MDist a s -> Int

Number of elements in the mutable distributed value.

• For debugging only, as code shouldn't be sensitive to the return value.

measureD :: a -> String

Show a distributed value.

• For debugging only.

Instances

DT Bool

DT Char

DT Double

DT Float

DT Int

DT Integer

DT Ordering

DT Word8

DT ()

DT UVSegd

DT USSegd

DT USegd

DT a => DT (Maybe a)

Unbox a => DT (Vector a)

(DT a, DT b) => DT (a, b)

(DT a, DT b, DT c) => DT (a, b, c)

Checking

checkGangD :: DT a => String -> Gang -> Dist a -> b -> b

Check that the sizes of the Gang and of the distributed value match.

checkGangMD :: DT a => String -> Gang -> MDist a s -> b -> b

Check that the sizes of the Gang and of the mutable distributed value match.

General Operations

newD :: DT a => Gang -> (forall s. MDist a s -> ST s ()) -> Dist a

Given a computation that can write its result to a mutable distributed value, run the computation to generate an immutable distributed value.

debugD :: DT a => Dist a -> String

Show all members of a distributed value.