safe

package

v0.1.6 Latest Latest Go to latest Published: Mar 19, 2026 License: AGPL-3.0 Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Queue[T any] struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Queue is a thread-safe linkedlist

func NewQueue[T any]() *Queue[T]

func (q *Queue[T]) Len() int

func (q *Queue[T]) PopBack() *T

func (q *Queue[T]) PopBackAll() []T

func (q *Queue[T]) PopBackN(n int) []T

func (q *Queue[T]) PushFront(v T) *list.Element

func (q *Queue[T]) PushFrontN(vs []T)

func (q *Queue[T]) RemoveAll()

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

QueueLimited is Queue with Limited Size

func NewQueueLimited[T any](maxSize int) *QueueLimited[T]

func (ql *QueueLimited[T]) Len() int

func (ql *QueueLimited[T]) PopBack() *T

func (ql *QueueLimited[T]) PopBackAll() []T

func (ql *QueueLimited[T]) PopBackN(n int) []T

func (ql *QueueLimited[T]) PushFront(v T) bool

func (ql *QueueLimited[T]) PushFrontN(vs []T) bool

func (ql *QueueLimited[T]) RemoveAll()