Reactor aware fixed size queue.
Unlike mecca.container.queue, this queue does not assert when an operation cannot be fulfilled. Instead, it blocks the calling fiber until the operation can be completed.
Pop a single element from the queue
Pushes an uninitialized item to the queue.
Add an item to the queue.
Wait until all current fibers waiting to push have done so.
Returns true if no items are currenlty queued.
Returns true if trying to add a new item would block.
the item type to be used.
the queue's capacity.
See Implementation
Reactor aware fixed size queue.
Unlike mecca.container.queue, this queue does not assert when an operation cannot be fulfilled. Instead, it blocks the calling fiber until the operation can be completed.