LockedQueue

Locked queue for inter-thread communication. Support multiple writers, multiple readers. Blocks threads either when empty or full.

Constructors

this
this(size_t capacity)
Undocumented in source.

Members

Functions

capacity
size_t capacity()
clear
void clear()

Removes all locked queue items.

popBack
T popBack()

Pop an item from the back, block if queue is empty.

popFront
T popFront()

Pop an item from the front, block if queue is empty.

pushBack
void pushBack(T x)

Push an item to the back, block if queue is full.

pushFront
void pushFront(T x)

Push an item to the front, block if queue is full.

See Also

Meta