Allow setting the number of max processes for parallel mode (#392)

* max processes

* simplify

* formatting

---------

Co-authored-by: Taylor Otwell <[email protected]>

Author: cosmastech

app/Actions/FixCode.php

@@ -5,6 +5,7 @@
 use App\Factories\ConfigurationResolverFactory;
 use LaravelZero\Framework\Exceptions\ConsoleException;
 use PhpCsFixer\Console\ConfigurationResolver;
+use PhpCsFixer\Runner\Parallel\ParallelConfig;
 use PhpCsFixer\Runner\Runner;
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Input\InputOption;
@@ -62,15 +63,35 @@ public function execute()
             $resolver->getCacheManager(),
             $resolver->getDirectory(),
             $resolver->shouldStopOnViolation(),
-            $resolver->getParallelConfig(),
+            $this->getParallelConfig($resolver),
             $this->getInput($resolver),
         ));
 
         return tap([$totalFiles, $changes], fn () => $this->progress->unsubscribe());
     }
 
     /**
-     * Gets the input for the PHP CS Fixer Runner.
+     * Get the ParallelConfig for the number of cores.
+     */
+    private function getParallelConfig(ConfigurationResolver $resolver): ParallelConfig
+    {
+        $maxProcesses = intval($this->input->getOption('max-processes') ?? 0);
+
+        if (! $this->input->getOption('parallel') || $maxProcesses < 1) {
+            return $resolver->getParallelConfig();
+        }
+
+        $parallelConfig = $resolver->getParallelConfig();
+
+        return new ParallelConfig(
+            $maxProcesses,
+            $parallelConfig->getFilesPerProcess(),
+            $parallelConfig->getProcessTimeout()
+        );
+    }
+
+    /**
+     * Get the input for the PHP CS Fixer Runner.
      */
     private function getInput(ConfigurationResolver $resolver): InputInterface
     {

app/Commands/DefaultCommand.php

@@ -50,6 +50,7 @@ protected function configure()
                     new InputOption('output-format', '', InputOption::VALUE_REQUIRED, 'The format that should be used when outputting the test results to a file'),
                     new InputOption('cache-file', '', InputArgument::OPTIONAL, 'The path to the cache file'),
                     new InputOption('parallel', 'p', InputOption::VALUE_NONE, 'Runs the linter in parallel (Experimental)'),
+                    new InputOption('max-processes', null, InputOption::VALUE_REQUIRED, 'The number of processes to spawn when using parallel execution'),
                 ],
             );
     }