priorityqueue

Documentation

Index

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

Variables

var (
	ErrContention = errors.New("contention")
)

Types

type PriorityQueue

type PriorityQueue struct {
	Queues []chan interface{}
	// contains filtered or unexported fields
}

PriorityQueue是基本结构

func New

func New(n int, l int) *PriorityQueue

New是PriorityQueue的构造函数

func (*PriorityQueue) Push

func (pq *PriorityQueue) Push(x interface{}, p int) error

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

func (*PriorityQueue) Run

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

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