Method Dequeue

pkg/flushqueues/priority_queue.go:111–131

Dequeue will return the op with the highest priority; block if queue is empty; returns the zero value of T if queue is closed.

()

// Dequeue will return the op with the highest priority; block if queue is
// empty; returns the zero value of T if queue is closed.
func (pq *PriorityQueue[T]) Dequeue() T {
	pq.lock.Lock()
	defer pq.lock.Unlock()

	for len(pq.queue) == 0 && !pq.closing && !pq.closed {
		pq.cond.Wait()
	}

	if len(pq.queue) == 0 && (pq.closing || pq.closed) {
		pq.closed = true
		var zero T
		return zero
	}

	op := heap.Pop(&pq.queue).(T)
	delete(pq.hit, op.Key())
	if pq.lengthGauge != nil {
		pq.lengthGauge.Dec()
	}
	return op
}