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.

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

NewWithContext is a constructor for a new threadsafe queue.

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.

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

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