Function newAsyncGate

interpreter/async.go:464–473

(maxConcurrency int, completions chan<- int64)

}

func newAsyncGate(maxConcurrency int, completions chan<- int64) *asyncGate {
	var sem chan struct{}
	if maxConcurrency > 0 {
		sem = make(chan struct{}, maxConcurrency)
	}
	return &asyncGate{
		semaphore:   sem,
		completions: completions,
	}
}

// TryAcquire attempts to acquire a concurrency slot and increments the active calls count.
func (g *asyncGate) TryAcquire() bool {