class ParallelTests::CLI

def execute_in_parallel(items, num_processes, options)
  Tempfile.open 'parallel_tests-lock' do |lock|
    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