priq

package

v1.2.6 Latest Latest Go to latest Published: Apr 16, 2024 License: MIT Imports: 3 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package priq 带优先级功的队列，可以进行select操作，并且有容量限制

This section is empty.

View Source

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

This section is empty.

type EntryList []*wrapEntry

func (e EntryList) Len() int

func (e EntryList) Less(i, j int) bool

Less 根据less从小到大排列，排在前面的先Pop（也就是优先级更高）

func (e *EntryList) Pop() interface{}

func (e *EntryList) Push(x interface{})

func (e EntryList) Swap(i, j int)

type IEntry interface {
	GetPriority() int
}

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

func NewPriQueue(capability int) *PriQueue

func (pq *PriQueue) Len() int

func (pq *PriQueue) Pop() IEntry

Pop 不阻塞，如果返回nil代表当前队列是空的

func (pq *PriQueue) Push(e IEntry) error

Push 不阻塞

func (pq *PriQueue) WaitCh() <-chan struct{}

WaitCh 对 WaitCh() 返回的channel进行select，然后再使用Pop