Control.Concurrent.Datastructures.BlockingConcurrentQueue

Documentation

data BlockingConcurrentQueue a

Constructors

BlockingConcurrentQueue

Fields

• queue :: MVar [a]
• threadWaitQueue :: ThreadWaitQueue

Instances

Show (BlockingConcurrentQueue a)

Methods

showsPrec :: Int -> BlockingConcurrentQueue a -> ShowS

show :: BlockingConcurrentQueue a -> String

showList :: [BlockingConcurrentQueue a] -> ShowS

showBlockingConcurrentQueue :: Show a => BlockingConcurrentQueue a -> IO [Char]

createBlockingConcurrentQueue :: IO (BlockingConcurrentQueue a)

putInBlockingConcurrentQueue :: BlockingConcurrentQueue a -> a -> IO ()

putAllInBlockingConcurrentQueue :: BlockingConcurrentQueue a -> [a] -> IO ()

takeFromBlockingConcurrentQueue :: BlockingConcurrentQueue a -> IO a

takeAllFromBlockingConcurrentQueue :: BlockingConcurrentQueue a -> IO [a]

readAllFromBlockingConcurrentQueue :: BlockingConcurrentQueue a -> IO [a]