Function runParallel

internal/databases/sqlserver/sqlserver.go:406–430

(f func(int) error, cnt int, concurrency int)

}

func runParallel(f func(int) error, cnt int, concurrency int) error {
	if concurrency <= 0 {
		concurrency = cnt
	}
	sem := make(chan struct{}, concurrency)
	errs := make(chan error, cnt)
	for i := 0; i < cnt; i++ {
		go func(i int) {
			sem <- struct{}{}
			defer func() { <-sem }()
			errs <- f(i)
		}(i)
	}
	var errStr string
	for i := 0; i < cnt; i++ {
		err := <-errs
		if err != nil {
			errStr += err.Error() + "\n"
		}
	}
	if errStr != "" {
		return errors.New(errStr)
	}
	return nil
}

func getDBConcurrency() int {
	concurrency, err := conf.GetMaxConcurrency(conf.SQLServerDBConcurrency)