Web.Spock.Worker.Internal.Queue

Documentation

data PureQueue p v

Constructors

PureQueue

Fields

• pq_container :: !(Map p (Vector v))
• pq_maxSize :: !Int

Instances

(Eq p, Eq v) => Eq (PureQueue p v)

Methods

(==) :: PureQueue p v -> PureQueue p v -> Bool

(/=) :: PureQueue p v -> PureQueue p v -> Bool

(Show p, Show v) => Show (PureQueue p v)

Methods

showsPrec :: Int -> PureQueue p v -> ShowS

show :: PureQueue p v -> String

showList :: [PureQueue p v] -> ShowS

emptyPQ :: Int -> PureQueue p v

sizePQ :: PureQueue p v -> Int

isFullPQ :: PureQueue p v -> Bool

toListPQ :: PureQueue p v -> [(p, [v])]

fromListPQ :: Ord p => Int -> [(p, [v])] -> Maybe (PureQueue p v)

maxPrioPQ :: PureQueue p v -> p

enqueuePQ :: Ord p => p -> v -> PureQueue p v -> (Bool, PureQueue p v)

dequeuePQ :: Ord p => p -> PureQueue p v -> (Maybe v, PureQueue p v)

dequeuePQ' :: Ord p => p -> PureQueue p v -> (Maybe (p, v), PureQueue p v)

newtype WorkerQueue p v

Constructors

WorkerQueue (TVar (PureQueue p v))

newQueue :: Int -> IO (WorkerQueue p v)

size :: WorkerQueue p v -> STM Int

isFull :: WorkerQueue p v -> STM Bool

enqueue :: Ord p => p -> v -> WorkerQueue p v -> STM ()

dequeue :: Ord p => p -> WorkerQueue p v -> STM (Maybe v)