Control.Distributed.Process.Internal.CQueue

Concurrent queue for single reader, single writer

Documentation

data CQueue a

data BlockSpec

Constructors

NonBlocking

Blocking

Timeout Int

newCQueue :: IO (CQueue a)

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

Enqueue an element

Enqueue is strict.

dequeue

Arguments

:: forall a b .

=> CQueue a

Queue

-> BlockSpec

Blocking behaviour

-> [a -> Maybe b]

List of matches

-> IO (Maybe b)

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))

Weak reference to a CQueue