Method Close

pkg/util/priority_queue.go:64–73

Close signals that the queue should be closed when it is empty. A closed queue will not accept new items.

()

// Close signals that the queue should be closed when it is empty.
// A closed queue will not accept new items.
func (pq *PriorityQueue) Close() {
	pq.lock.Lock()
	defer pq.lock.Unlock()
	if len(pq.queue) > 0 {
		pq.closing = true
	} else {
		pq.closed = true
	}
	pq.cond.Broadcast()
}

// DiscardAndClose closes the queue and removes all the items from it.
func (pq *PriorityQueue) DiscardAndClose() {