distributed-process-0.4.2: Cloud Haskell: Erlang-style concurrency in Haskell

Safe HaskellNone

Control.Distributed.Process.Internal.CQueue

Description

Concurrent queue for single reader, single writer

Synopsis

Documentation

data CQueue a Source

data BlockSpec Source

Constructors

NonBlocking 
Blocking 
Timeout Int 

data MatchOn m a Source

Constructors

MatchMsg (m -> Maybe a) 
MatchChan (STM a) 

newCQueue :: IO (CQueue a)Source

enqueue :: CQueue a -> a -> IO ()Source

Enqueue an element

Enqueue is strict.

dequeueSource

Arguments

:: forall m a .  
=> CQueue m

Queue

-> BlockSpec

Blocking behaviour

-> [MatchOn m a]

List of matches

-> IO (Maybe a)

Nothing only on timeout

Dequeue an element

The timeout (if any) is applied only to waiting for incoming messages, not to checking messages that have already arrived

mkWeakCQueue :: CQueue a -> IO () -> IO (Weak (CQueue a))Source

Weak reference to a CQueue