Function runInParallel

cli/command_benchmark.go:67–82

(args []A, run func(arg A) T)

}

func runInParallel[A, T any](args []A, run func(arg A) T) T {
	var wg sync.WaitGroup

	for _, arg := range args[1:] {
		wg.Go(func() {
			run(arg)
		})
	}

	// run one on the main goroutine and N-1 in parallel.
	v := run(args[0])

	wg.Wait()

	return v
}

func makeOutputBuffers(n, capacity int) []*bytes.Buffer {
	var res []*bytes.Buffer