From 880808dfb94d9957dab5305b33d9ed6a2df30f9d Mon Sep 17 00:00:00 2001 From: Paul Holzinger Date: Wed, 18 Jun 2025 14:41:22 +0200 Subject: [PATCH] pkg/parallel: remove deadcode Signed-off-by: Paul Holzinger --- pkg/parallel/parallel.go | 11 ----------- 1 file changed, 11 deletions(-) diff --git a/pkg/parallel/parallel.go b/pkg/parallel/parallel.go index 990c365cc8..64dc77ef5d 100644 --- a/pkg/parallel/parallel.go +++ b/pkg/parallel/parallel.go @@ -11,10 +11,6 @@ import ( ) var ( - // Maximum number of jobs that will be used. - // Set a low, but non-zero, default. We'll be overriding it by default - // anyways. - numThreads uint = 8 // Semaphore to control thread creation and ensure numThreads is // respected. jobControl *semaphore.Weighted @@ -32,19 +28,12 @@ func SetMaxThreads(threads uint) error { jobControlLock.Lock() defer jobControlLock.Unlock() - numThreads = threads jobControl = semaphore.NewWeighted(int64(threads)) logrus.Infof("Setting parallel job count to %d", threads) return nil } -// GetMaxThreads returns the current number of threads that will be used for -// parallel jobs. -func GetMaxThreads() uint { - return numThreads -} - // Enqueue adds a single function to the parallel jobs queue. This function will // be run when an unused thread is available. // Returns a receive-only error channel that will return the error (if any) from