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| mode = (RUBY_ENGINE == "jruby" ? :in_threads : :in_processes) return Parallel.map(items, mode => num_processes) do |item| result = yield(item) report_output(result, lock) if options[:serialize_stdout] result end end end