Method Dequeue

util/priority_queue.go:35–38

()

}

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

func (pq *PriorityQueue) Len() int {
	pq.lock.RLock()