Method asyncQueueProcessLoop

cache/async_queue.go:47–58

()

}

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

	for {
		select {
		case op := <-q.queueCh:
			op()
		case <-q.stopCh:
			return
		}
	}
}