Method stop

cache/async_queue.go:42–45

()

}

func (q *asyncQueue) stop() {
	close(q.stopCh)
	q.workers.Wait()
}

func (q *asyncQueue) asyncQueueProcessLoop() {
	defer q.workers.Done()