class SSHKit::Runner::Parallel
Public Instance Methods
execute()
click to toggle source
# File lib/sshkit/runners/parallel.rb, line 8 def execute threads = hosts.map do |host| Thread.new(host) do |h| begin backend(h, &block).run rescue StandardError => e e2 = ExecuteError.new e raise e2, "Exception while executing #{host.user ? "as #{host.user}@" : "on host "}#{host}: #{e.message}" end end end threads.each(&:join) end