boundedq

Documentation

Index

• func FindNearestPowerOf2(n uint32) uint32
• type BoundedQueue
  • func NewBoundedQueue(cap uint32) *BoundedQueue
  • func (q *BoundedQueue) Cap() uint32
  • func (q *BoundedQueue) Len() uint32
  • func (q *BoundedQueue) Pop(wait bool, waitTime int64) int
  • func (q *BoundedQueue) Push(x int)

Functions

func FindNearestPowerOf2

func FindNearestPowerOf2(n uint32) uint32

Types

type BoundedQueue

type BoundedQueue struct {
	// contains filtered or unexported fields
}

BoundedQueue is a thread-safe bounded queue.

func NewBoundedQueue

func NewBoundedQueue(cap uint32) *BoundedQueue

NewBoundedQueue returns a new BoundedQueue instance.

func (*BoundedQueue) Cap

func (q *BoundedQueue) Cap() uint32

Len returns the capacity of the queue.

func (*BoundedQueue) Len

func (q *BoundedQueue) Len() uint32

Len returns the length of the queue.

func (*BoundedQueue) Pop

func (q *BoundedQueue) Pop(wait bool, waitTime int64) int

Pop gets and removes conn from the queue. If waitTime <= 0, which means block waiting for Pop.

func (*BoundedQueue) Push

func (q *BoundedQueue) Push(x int)

Push adds conn into the queue.