Data.Array.Parallel.Unlifted.Distributed.Gang

Gang primitives.

Documentation

data Gang

A Gang is a group of threads which execute arbitrary work requests.

Instances

Show Gang

seqGang :: Gang -> Gang

A sequential gang has no threads.

forkGang :: Int -> IO Gang

Fork a Gang with the given number of threads (at least 1).

gangSize :: Gang -> Int

O(1). Yield the number of threads in the Gang.

gangIO :: Gang -> (Int -> IO ()) -> IO ()

Issue work requests for the Gang and wait until they have been executed. If the gang is already busy then just run the action in the requesting thread.

gangST :: Gang -> (Int -> ST s ()) -> ST s ()

Same as gangIO but in the ST monad.

traceGang :: String -> IO ()

Emit a GHC event for debugging.

traceGangST :: String -> ST s ()

Emit a GHC event for debugging, in the ST monad.