Function runCommandInThread

ng-dev/format/run-commands-parallel.ts:86–130

(thread: number)

    // Recursively run the command on the next available file from the list using the provided
    // thread.
    function runCommandInThread(thread: number) {
      const nextCommand = pendingCommands.pop();
      // If no file was pulled from the array, return as there are no more files to run against.
      if (nextCommand === undefined) {
        threads[thread] = false;
        return;
      }

      // Get the file and formatter for the next command.
      const {file, formatter} = nextCommand;

      if (lstatSync(file).isSymbolicLink()) {
        throw new Error(`Security violation: symlink detected for file ${file}`);
      }

      const [spawnCmd, ...spawnArgs] = [...formatter.commandFor(action), '--', file];

      ChildProcess.spawn(spawnCmd, spawnArgs, {
        suppressErrorOnFailingExitCode: true,
        mode: 'silent',
      }).then(({stdout, stderr, status}: SpawnResult) => {
        // Run the provided callback function.
        const failed = formatter.callbackFor(action)(file, status, stdout, stderr);
        if (failed) {
          failures.push({filePath: file, message: stderr});
        }
        // Note in the progress bar another file being completed.
        progressBar.increment(1);
        // If more files exist in the list, run again to work on the next file,
        // using the same slot.
        if (pendingCommands.length) {
          return runCommandInThread(thread);
        }
        // If not more files are available, mark the thread as unused.
        threads[thread] = false;
        // If all of the threads are false, as they are unused, mark the progress bar
        // completed and resolve the promise.
        if (threads.every((active) => !active)) {
          progressBar.stop();
          resolve(failures);
        }
      });
      // Mark the thread as in use as the command execution has been started.
      threads[thread] = true;
    }

    // Start the progress bar
    progressBar.start(pendingCommands.length, 0);