The number of jobs in library detection now follows --jobs flag

Author: cmaglie

internal/arduino/builder/builder.go

@@ -322,6 +322,7 @@ func (b *Builder) preprocess() error {
 		b.librariesBuildPath,
 		b.buildProperties,
 		b.targetPlatform.Platform.Architecture,
+		b.jobs,
 	)
 	if err != nil {
 		return err

internal/arduino/builder/internal/detector/detector.go

@@ -209,8 +209,9 @@ func (l *SketchLibrariesDetector) FindIncludes(
 	librariesBuildPath *paths.Path,
 	buildProperties *properties.Map,
 	platformArch string,
+	jobs int,
 ) error {
-	err := l.findIncludes(ctx, buildPath, buildCorePath, buildVariantPath, sketchBuildPath, sketch, librariesBuildPath, buildProperties, platformArch)
+	err := l.findIncludes(ctx, buildPath, buildCorePath, buildVariantPath, sketchBuildPath, sketch, librariesBuildPath, buildProperties, platformArch, jobs)
 	if err != nil && l.onlyUpdateCompilationDatabase {
 		l.logger.Info(
 			fmt.Sprintf(
@@ -234,6 +235,7 @@ func (l *SketchLibrariesDetector) findIncludes(
 	librariesBuildPath *paths.Path,
 	buildProperties *properties.Map,
 	platformArch string,
+	jobs int,
 ) error {
 	librariesResolutionCache := buildPath.Join("libraries.cache")
 	if l.useCachedLibrariesResolution && librariesResolutionCache.Exist() {
@@ -256,7 +258,7 @@ func (l *SketchLibrariesDetector) findIncludes(
 	}
 
 	// Pre-run cache entries
-	l.preRunner = runner.New(ctx)
+	l.preRunner = runner.New(ctx, jobs)
 	for _, entry := range l.cache.EntriesAhead() {
 		if entry.Compile != nil && entry.CompileTask != nil {
 			upToDate, _ := entry.Compile.ObjFileIsUpToDate()
@@ -307,7 +309,7 @@ func (l *SketchLibrariesDetector) findIncludes(
 
 			// Create a new pre-runner if the previous one was cancelled
 			if l.preRunner == nil {
-				l.preRunner = runner.New(ctx)
+				l.preRunner = runner.New(ctx, jobs)
 				// Push in the remainder of the queue
 				for _, sourceFile := range *sourceFileQueue {
 					l.preRunner.Enqueue(l.gccPreprocessTask(sourceFile, buildProperties))

internal/arduino/builder/internal/runner/runner.go

@@ -41,7 +41,9 @@ func (cmd *enqueuedCommand) String() string {
 	return cmd.task.String()
 }
 
-func New(inCtx context.Context) *Runner {
+// New creates a new Runner with the given number of workers.
+// If workers is 0, the number of workers will be the number of available CPUs.
+func New(inCtx context.Context, workers int) *Runner {
 	ctx, cancel := context.WithCancel(inCtx)
 	queue := make(chan *enqueuedCommand, 1000)
 	r := &Runner{
@@ -52,7 +54,10 @@ func New(inCtx context.Context) *Runner {
 	}
 
 	// Spawn workers
-	for i := 0; i < runtime.NumCPU(); i++ {
+	if workers == 0 {
+		workers = runtime.NumCPU()
+	}
+	for i := 0; i < workers; i++ {
 		r.wg.Add(1)
 		go func() {
 			worker(ctx, queue)

internal/arduino/builder/internal/runner/runner_test.go

@@ -28,7 +28,7 @@ import (
 func TestRunMultipleTask(t *testing.T) {
 	ctx, cancel := context.WithTimeout(context.Background(), time.Second*5)
 	defer cancel()
-	r := runner.New(ctx)
+	r := runner.New(ctx, 0)
 	r.Enqueue(runner.NewTask("bash", "-c", "sleep 1 ; echo -n 0"))
 	r.Enqueue(runner.NewTask("bash", "-c", "sleep 2 ; echo -n 1"))
 	r.Enqueue(runner.NewTask("bash", "-c", "sleep 3 ; echo -n 2"))