gang-of-threads-3.2.0: Non-deterministic parallelism with bags

Safe HaskellSafe-Inferred

Control.Concurrent.Bag.TaskBufferSTM

Documentation

data TaskBufferSTM a Source

Constructors

TaskBufferSTM 

Fields

writeBufferSTM :: a -> STM ()
 
unGetBufferSTM :: a -> STM ()
 
readBufferSTM :: STM a
 
tryReadBufferSTM :: STM (Maybe a)
 
isEmptyBufferSTM :: STM Bool
 

data BufferType Source

Constructors

Queue 
Stack 

type SplitFunction r = TaskBufferSTM (IO (Maybe r)) -> TaskBufferSTM (IO (Maybe r)) -> STM (IO (Maybe r))Source

takeFirst :: SplitFunction rSource

splitVertical :: SplitFunction rSource

splitHalf :: SplitFunction rSource

newChanBufferSTM :: STM (TaskBufferSTM r)Source

newStackBufferSTM :: STM (TaskBufferSTM r)Source