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