WithQueueLen exmaple

vbauerster · Jan 3, 2025 · 1fac6fb · 1fac6fb
1 parent 4b3415c
commit 1fac6fb
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/_examples/stress/main.go b/_examples/stress/main.go
@@ -29,7 +29,11 @@ func main() {
 	}
 	var wg sync.WaitGroup
 	// passed wg will be accounted at p.Wait() call
-	p := mpb.New(mpb.WithWaitGroup(&wg), mpb.WithDebugOutput(os.Stderr))
+	p := mpb.New(
+		mpb.WithWaitGroup(&wg),
+		mpb.WithDebugOutput(os.Stderr),
+		mpb.WithQueueLen(totalBars), // totalBars is known ahead of time so overriding default queue len is good idea
+	)
 	wg.Add(totalBars)
 
 	for i := 0; i < totalBars; i++ {