- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for ParallelizeUntil (0.12 sec)
-
pkg/scheduler/framework/parallelize/parallelism.go
s := int(math.Sqrt(float64(n))) if r := n/parallelism + 1; s > r { s = r } else if s < 1 { s = 1 } return s } // Until is a wrapper around workqueue.ParallelizeUntil to use in scheduling algorithms. // A given operation will be a label that is recorded in the goroutine metric. func (p Parallelizer) Until(ctx context.Context, pieces int, doWorkPiece workqueue.DoWorkPieceFunc, operation string) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 09 17:12:30 UTC 2023 - 2K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
// can take a while if we're processing each node serially as well. So we // process them with bounded concurrency instead, since most of the time is // spent waiting on io. workqueue.ParallelizeUntil(ctx, nc.nodeUpdateWorkerSize, len(nodes), updateNodeFunc) nc.handleDisruption(ctx, zoneToNodeConditions, nodes) return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0)