priorityqueue

Documentation

Index

• type PriorityQueue
  • func New(n int, l int) *PriorityQueue
  • func (pq *PriorityQueue) Push(ctx context.Context, x interface{}, p int) error
  • func (pq *PriorityQueue) Run(ctx context.Context, f func(interface{}))

Types

type PriorityQueue

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

PriorityQueue是基本结构

func New

func New(n int, l int) *PriorityQueue

New是PriorityQueue的构造函数

func (*PriorityQueue) Push

func (pq *PriorityQueue) Push(ctx context.Context, x interface{}, p int) error

push将项目推送到priority参数中指定的适当队列 如果给定了上下文，它将一直等到推送该项或上下文中止为止。 否则，如果队列已满，则返回errCompetition

func (*PriorityQueue) Run

func (pq *PriorityQueue) Run(ctx context.Context, f func(interface{}))

运行是从队列中弹出项目的永久循环