Function runParallelBench

queues/benchutils_test.go:13–27

(b *testing.B, numRoutines int, q Queue, test func(Queue, int))

)

func runParallelBench(b *testing.B, numRoutines int, q Queue, test func(Queue, int)) {
	if useFixedBench {
		b.N = benchIterations
	}
	N := b.N / numRoutines
	wg := &sync.WaitGroup{}
	for i := 0; i < numRoutines; i += 1 {
		wg.Add(1)
		go func(){
			test(q, N)
			wg.Done()
		}()
	}
	wg.Wait()
}

func benchANRN(q Queue, N int){
	for i := 0; i < N; i += 1 {