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

Safe HaskellSafe-Inferred

Control.Concurrent.Bag.TaskBuffer

Documentation

data TaskBufferSTM a Source

Constructors

TaskBufferSTM 

Fields

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

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

data BufferType Source

Constructors

Queue 
Stack 

newChanBuffer :: STM (TaskBufferSTM r)Source

newStackBuffer :: STM (TaskBufferSTM r)Source