queue

package

v1.4.0 Latest Latest Go to latest Published: Mar 3, 2026 License: Apache-2.0 Imports: 0 Imported by: 0

Details

Package queue provides a bounded channel-based queue.

This section is empty.

This section is empty.

This section is empty.

type Queue struct {
	PoolSize int
	PoolChan chan interface{}
}

Queue is a bounded channel-based queue.

func NewQueue(size int) *Queue

NewQueue creates a new Queue with the given capacity.

func (this *Queue) Exchange(num int) (add int)

Exchange resizes the queue for reuse. Returns the number of items that can be added.

func (this *Queue) Init(size int) *Queue

Init reinitializes the Queue with a new capacity.

func (this *Queue) Pull() interface{}

Pull removes and returns an item from the queue.

func (this *Queue) Push(i interface{}) bool

Push adds an item to the queue. Returns false if the queue is full.

func (this *Queue) PushSlice(s []interface{})

PushSlice adds all items from the slice to the queue.