Function benchmarkPool

pkg/sfu/receiver_test.go:112–130

(b *testing.B, wp *workerpool.WorkerPool, buckets []int)

}

func benchmarkPool(b *testing.B, wp *workerpool.WorkerPool, buckets []int) {
	for b.Loop() {
		var wg sync.WaitGroup
		for j := range buckets {
			downTracks := buckets[j]
			if downTracks == 0 {
				continue
			}
			wg.Add(1)
			wp.Submit(func() {
				defer wg.Done()
				for dt := 0; dt < downTracks; dt++ {
					writeRTP()
				}
			})
		}
		wg.Wait()
	}
}

func benchmarkGoroutine(b *testing.B, buckets []int) {
	for b.Loop() {