queue

package

v0.0.2 Latest Latest Go to latest Published: Jul 9, 2023 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

func New[Value any](opts ...options.Option[Queue[Value]]) core.Queue[Value]

func WithCapacity[Value any](c int) options.Option[Queue[Value]]

type Queue[Value any] struct {
	// contains filtered or unexported fields
}

Queue is a lock-free queue implemented with linked list, based on atomic compare-and-swap operations.

func (q *Queue[Value]) Dequeue() (Value, bool)

func (q *Queue[Value]) Empty() bool

func (q *Queue[Value]) Enqueue(v Value) bool

func (q *Queue[Value]) Full() bool

func (q *Queue[Value]) Range(iterator func(val Value) bool)

func (q *Queue[Value]) Size() int