queue

package

v0.0.2 Latest Latest Go to latest Published: Nov 11, 2022 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type OptionPrioQueue func(*PrioQueue) error

func OptionQueueLen(length int) OptionPrioQueue

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

func NewPrioQueue(opts ...OptionPrioQueue) (*PrioQueue, error)

default queue priority 1, the higher the value, the higher the priority.

func (pq *PrioQueue) Available() int

func (pq *PrioQueue) Len() int

func (pq *PrioQueue) Pop() interface{}

func (pq *PrioQueue) PopSync() interface{}

func (pq *PrioQueue) PrioPush(prio int, data interface{}) error

func (pq *PrioQueue) Push(data interface{}) error