1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109
|
package graph
type prioQueue struct {
heap []int // vertices in heap order
index []int // index of each vertex in the heap
cost []int64
}
func emptyPrioQueue(cost []int64) *prioQueue {
return &prioQueue{
index: make([]int, len(cost)),
cost: cost,
}
}
func newPrioQueue(cost []int64) *prioQueue {
n := len(cost)
q := &prioQueue{
heap: make([]int, n),
index: make([]int, n),
cost: cost,
}
for i := range q.heap {
q.heap[i] = i
q.index[i] = i
}
return q
}
// Len returns the number of elements in the queue.
func (q *prioQueue) Len() int {
return len(q.heap)
}
// Push pushes v onto the queue.
// The time complexity is O(log n) where n = q.Len().
func (q *prioQueue) Push(v int) {
n := q.Len()
q.heap = append(q.heap, v)
q.index[v] = n
q.up(n)
}
// Pop removes the minimum element from the queue and returns it.
// The time complexity is O(log n) where n = q.Len().
func (q *prioQueue) Pop() int {
n := q.Len() - 1
q.swap(0, n)
q.down(0, n)
v := q.heap[n]
q.index[v] = -1
q.heap = q.heap[:n]
return v
}
// Contains tells whether v is in the queue.
func (q *prioQueue) Contains(v int) bool {
return q.index[v] >= 0
}
// Fix re-establishes the ordering after the cost for v has changed.
// The time complexity is O(log n) where n = q.Len().
func (q *prioQueue) Fix(v int) {
if i := q.index[v]; !q.down(i, q.Len()) {
q.up(i)
}
}
func (q *prioQueue) less(i, j int) bool {
return q.cost[q.heap[i]] < q.cost[q.heap[j]]
}
func (q *prioQueue) swap(i, j int) {
q.heap[i], q.heap[j] = q.heap[j], q.heap[i]
q.index[q.heap[i]] = i
q.index[q.heap[j]] = j
}
func (q *prioQueue) up(j int) {
for {
i := (j - 1) / 2 // parent
if i == j || !q.less(j, i) {
break
}
q.swap(i, j)
j = i
}
}
func (q *prioQueue) down(i0, n int) bool {
i := i0
for {
j1 := 2*i + 1
if j1 >= n || j1 < 0 { // j1 < 0 after int overflow
break
}
j := j1 // left child
if j2 := j1 + 1; j2 < n && q.less(j2, j1) {
j = j2 // = 2*i + 2 // right child
}
if !q.less(j, i) {
break
}
q.swap(i, j)
i = j
}
return i > i0
}
|