Safe Haskell | None |
---|
Concurrent queue for single reader, single writer
- data CQueue a
- data BlockSpec
- = NonBlocking
- | Blocking
- | Timeout Int
- data MatchOn m a
- newCQueue :: IO (CQueue a)
- enqueue :: CQueue a -> a -> IO ()
- enqueueSTM :: CQueue a -> a -> STM ()
- dequeue :: forall m a. CQueue m -> BlockSpec -> [MatchOn m a] -> IO (Maybe a)
- mkWeakCQueue :: CQueue a -> IO () -> IO (Weak (CQueue a))
Documentation
enqueueSTM :: CQueue a -> a -> STM ()Source
Variant of enqueue for use in the STM monad.