queue

package

v0.0.0-...-6c767d1 Latest Latest Go to latest Published: Jun 17, 2025 License: Apache-2.0 Imports: 2 Imported by: 0

Details

View Source

const DefaultQueueSize = 256

This section is empty.

This section is empty.

type FixedQueue[T any] struct {
	// contains filtered or unexported fields
}

func NewFixedQueue[T any](n int) *FixedQueue[T]

NewFixedQueue returns a pointer to a queue whose capacity is the next power of two equal to or greater than n (minimum 2).

func (q *FixedQueue[T]) Cap() int64

func (q *FixedQueue[T]) Len() int64

func (q *FixedQueue[T]) Pop() (T, bool)

func (q *FixedQueue[T]) PopAtomic() (T, PopResult)

func (q *FixedQueue[T]) Push(v T) bool

Push attempts to push v into the queue. Returns false if the queue is full.

func (q *FixedQueue[T]) PushAtomic(v T) PushResult

type MemorySize interface {
	MemoryUsage() uint64
}

type PopResult int

const (
	PopFailed PopResult = iota - 1
	PopSuccess
	PopEmpty
)

func (r PopResult) IsSuccess() bool

func (r PopResult) String() string

type PushResult int

const (
	PushFailed PushResult = iota - 1
	PushSuccess
	PushFull
)

func (r PushResult) IsSuccess() bool

func (r PushResult) String() string

type Queue[T any] interface {
	Len() uint64
	Cap() uint64
	PushAtomic(T) PushResult
	Push(v T) bool
	PopAtomic() (T, PopResult)
	Pop() (T, bool)
}