class ParallelTests::CLI

def execute_in_parallel(items, num_processes, options)

def execute_in_parallel(items, num_processes, options)
  Tempfile.open 'parallel_tests-lock' do |lock|
    ParallelTests.with_pid_file do
      progress_indicator = simulate_output_for_ci if options[:serialize_stdout]
      Parallel.map(items, :in_threads => num_processes) do |item|
        result = yield(item)
        if progress_indicator && progress_indicator.alive?
          progress_indicator.exit
          puts
        end
        reprint_output(result, lock.path) if options[:serialize_stdout]
        result
      end
    end
  end
end