Ruby 和 Threads - 为什么我的脚本没有完成？

Question

我有一个脚本可以使用 Thread 为集群远程配置节点，这样我就可以一次完成所有这些任务。

有没有更好的方法可以让我获得返回码、干净的退出以及似乎不会运行超长时间的脚本？

@threads = []

def process_node(apps_to_close, node)
  @threads << Thread.new do
    puts "now processing node #{node}\n"
    ...
  end
end

nodes.each do |node|
  process_node(apps_to_close, node)
end

@threads.each {|thr| thr.join}

Answer 1

您可以通过 join 限制线程运行的时间。 ，如果达到超时时线程仍在运行，则返回 nil。所以你可以将其重写为:

...

results = @threads.collect { |thr| thr.join(1) } # wait 1 second for thread
@threads.each { |t| Thread.kill(t) }
results.any?(&:nil?) ? exit(1) : exit(0)