Method Enqueue

util/priority_queue.go:31–33

(x interface{}, sourceId int)

}

func (pq *PriorityQueue) Enqueue(x interface{}, sourceId int) {
	heap.Push(pq, &Item{value: x, sourceId: sourceId})
}

func (pq *PriorityQueue) Dequeue() (interface{}, int) {
	item := heap.Pop(pq).(*Item)