ExecuteInParallel will (in parallel) call the provided function with each item in the queue until the queue is exhausted.

New is a constructor for a new threadsafe queue.

NewPriorityQueue is the constructor for a priority queue.

NewRingBuffer will allocate, initialize, and return a ring buffer with the specified size.

ErrDisposed is returned when an operation is performed on a disposed queue.

ErrEmptyQueue is returned when an non-applicable queue operation was called due to the queue's empty item state.

ErrTimeout is returned when an applicable queue operation times out.

PriorityQueue is similar to queue except that it takes items that implement the Item interface and adds them to the queue in priority order.

Queue is the struct responsible for tracking the state of the queue.

RingBuffer is a MPMC buffer that achieves threadsafety with CAS operations only.

Item is an item that can be added to the priority queue.