distributed-process-0.3.1: Cloud Haskell: Erlang-style concurrency in Haskell
Control.Distributed.Process.Internal.CQueue
Description
Concurrent queue for single reader, single writer
Synopsis
data CQueue a Source
data BlockSpec Source
Constructors
newCQueue :: IO (CQueue a)Source
enqueue :: CQueue a -> a -> IO ()Source
dequeueSource
Arguments
Queue
Blocking behaviour
List of matches
Nothing only on timeout
Nothing
Dequeue an element
The timeout (if any) is applied only to waiting for incoming messages, not to checking messages that have already arrived