Ruby: #call_parallel

call_parallel.rb

#
# Run multiple system commands in parallel
#
def call_parallel(cmds = [], check_interval = nil)
  if cmds.size > 0
    threads, results = [], []
    cmds.each do |cmd|
      threads << Thread.new { results << [cmd, `#{cmd}`, $?] }
    end
    is_done = false
    check_interval = 0.2 if check_interval.nil?
    while is_done == false do
      sleep check_interval
      done = true
      threads.each { |thread| done = false if thread.status != false }
      is_done = true if done
    end
    yield(results)
  end
end

#
# Example usage
#
cmds = [ "lsof | grep ruby", "echo 'hello world'" ]
call_parallel(cmds) do |results|
  results.each do |result|
    puts "------------------------------------------"
    puts "   Command: #{result[0]}"
    puts " Exit code: #{result[2].to_i}"
    puts "    Output: "
    puts "#{result[1]}"
  end
end