queue

package

v1.1.6 Latest Latest Go to latest Published: Feb 25, 2026 License: MIT Imports: 2 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Queue 封装了 UMPSCQueue 和计数器

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

New 创建一个新的 Queue 实例

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

Dequeue 从队列中获取数据并更新计数器 (仅单消费者!!!)

func (q *Queue[T]) Enqueue(value T)

Enqueue 向队列中添加数据并更新计数器 (多生产者: 安全)

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

Len 返回当前队列长度

func (q *Queue[T]) RateState() (rate float64, enqueueCount, lastEnqueueCount uint64)

RateState 返回入队速率, 当前计数, 上一次计数