Method submit

cache/async_queue.go:33–40

submit adds an operation to the queue or returns an error if the queue is full

(op func())

// submit adds an operation to the queue or returns an error if the queue is full
func (q *asyncQueue) submit(op func()) error {
	select {
	case q.queueCh <- op:
		return nil
	default:
		return errAsyncQueueFull
	}
}

func (q *asyncQueue) stop() {
	close(q.stopCh)