queue

package

v0.3.7 Latest Latest Go to latest Published: Aug 1, 2024 License: GPL-2.0 Imports: 3 Imported by: 0

Details

This section is empty.

View Source

var ErrQueueIsEmpty = errors.New("queue is empty")

View Source

var ErrQueueIsEmptyTimeout = errors.New("queue is empty timeout")

View Source

var ErrQueueIsFull = errors.New("queue is full")

View Source

var ErrQueueIsFullTimeout = errors.New("queue is full timeout")

This section is empty.

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

func NewPacketQueue(length int) *Queue[*packet.Packet]

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

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

func (q *Queue[T]) Pop(handle func(T))

Pop 获取数据，非阻塞 (handle将阻塞获取)

func (q *Queue[T]) PopBlock() (pkg T)

PopBlock 获取数据，阻塞

func (q *Queue[T]) PopJudge() (pkg T, err error)

PopJudge 获取数据，非阻塞，如果队列为空则放弃获取

func (q *Queue[T]) PopSig() chan T

func (q *Queue[T]) PopTimeout(timeout time.Duration) (pkg T, err error)

PopTimeout 获取数据，阻塞，如果超时则放弃

func (q *Queue[T]) Push(pkg T)

Push 推送到队列，非阻塞

func (q *Queue[T]) PushBlock(pkg T)

PushBlock 推送到队列，阻塞

func (q *Queue[T]) PushJudge(pkg T) error

PushJudge 推送到队列，非阻塞，如果队列已满则放弃推送

func (q *Queue[T]) PushTimeout(pkg T, timeout time.Duration) error

PushTimeout 推送到队列，阻塞，如果超时则放弃