github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-23 19:56:01 +00:00
Code Issues Projects Releases Wiki Activity

Avoid metric lookup in Parallelizer.Util on every work piece

Browse Source
This commit is contained in:
Maciej Borsz 2023-03-09 17:09:36 +00:00
parent f90643435e
commit 30bca1e1d5
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/scheduler/framework/parallelize/parallelism.go
View File

@ -54,10 +54,11 @@ func chunkSizeFor(n, parallelism int) int {
// Until is a wrapper around workqueue.ParallelizeUntil to use in scheduling algorithms. // 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. // 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) { func (p Parallelizer) Until(ctx context.Context, pieces int, doWorkPiece workqueue.DoWorkPieceFunc, operation string) {
goroutinesMetric := metrics.Goroutines.WithLabelValues(operation)
withMetrics := func(piece int) { withMetrics := func(piece int) {
metrics.Goroutines.WithLabelValues(operation).Inc() goroutinesMetric.Inc()
defer metrics.Goroutines.WithLabelValues(operation).Dec()
doWorkPiece(piece) doWorkPiece(piece)
goroutinesMetric.Dec()
} }
workqueue.ParallelizeUntil(ctx, p.parallelism, pieces, withMetrics, workqueue.WithChunkSize(chunkSizeFor(pieces, p.parallelism))) workqueue.ParallelizeUntil(ctx, p.parallelism, pieces, withMetrics, workqueue.WithChunkSize(chunkSizeFor(pieces, p.parallelism)))