priorityqueue

Nov 14, 2018

Changes in this version

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

type PriorityQueue

+ Queues []chan interface{}

Jul 4, 2018

Changes in this version

+ type PriorityQueue struct

+ 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{}))