Method Go

util/multierr/errwaitgroup.go:55–70

Go calls the given function in a new goroutine. It blocks until the new goroutine can be added without the number of active goroutines in the group exceeding the configured limit.

(f func() error)

// It blocks until the new goroutine can be added without the number of
// active goroutines in the group exceeding the configured limit.
func (g *ErrWaitGroup) Go(f func() error) {
	if g.sem != nil {
		g.sem <- token{}
	}

	g.wg.Add(1)
	go func() {
		defer g.done()

		if err := f(); err != nil {
			g.mu.Lock()
			g.err = Join(g.err, err)
			g.mu.Unlock()
		}
	}()
}

// TryGo calls the given function in a new goroutine only if the number of
// active goroutines in the group is currently below the configured limit.