Debug

kubernetes-sigs · Nov 27, 2024 · c55737a · c55737a
1 parent 5f40b20
commit c55737a
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/pkg/utils/queue/parallelism.go b/pkg/utils/queue/parallelism.go
@@ -30,6 +30,9 @@ type Parallelism[T any] struct {
 
 func NewParallelismQueue[T any](ctx context.Context, q Queue[T], startFunc func(ctx context.Context)) *Parallelism[T] {
 	go startFunc(ctx)
+	go startFunc(ctx)
+	go startFunc(ctx)
+	go startFunc(ctx)
 
 	return &Parallelism[T]{
 		ctx:         ctx,
@@ -45,7 +48,8 @@ func (p *Parallelism[T]) GetOrWaitWithDone(done <-chan struct{}) (T, bool) {
 		return t, false
 	}
 
-	if p.Len() > 10 {
+	length := p.Len()
+	if length > 3 {
 		now := time.Now()
 		if now.Sub(p.latestStart) > time.Second {
 			go p.startFunc(p.ctx)