如何等待线程通知而不是加入所有线程？

Question

简而言之，用户向我的 Web 服务发出请求，我必须将请求转发到 X 个不同的 API。我应该并行执行，所以我为此创建线程，并且第一个回答有效响应的线程，我应该终止其余线程并立即将答案返回给我的客户。

Ruby 中的一个常见模式是创建多个线程，例如

threads << Thread.new {}
threads.each { |t| t.join }

我已有的逻辑是这样的：

results = []
threads = []
valid_answer = nil

1.upto(10) do |i|
  threads = Thread.new do
    sleep(rand(60))
    results << i
  end
end

threads.each { |t| t.join }

valid_answer = results.detect { |r| r > 7 }

但是在类似前面的代码中，我会阻塞进程，直到所有线程都完成。可能是一个线程会在 1 秒内回复一个有效的答案（所以此时我应该杀死所有其他线程并返回那个答案），但是相反，我加入了所有线程并且没有太有道理了。

在 ruby​​ 中是否有一种方法可以休眠或等到一个线程回答，检查该回答是否有效，然后再次阻塞/休眠，直到所有线程都完成，或者直到其中一个线程给我一个有效的响应?

---

编辑：

应该并行进行。当我收到客户的请求时，我可以将请求转发给 5 家不同的公司。

每家公司最多可以有 60 秒的超时时间（疯狂但真实的医疗保健业务）。

一旦其中一家公司回复，我必须检查回复（如果是真实回复或错误），如果是真实回复，我应该杀死所有其他线程并立即回复客户（如果其中一个请求让我返回超时，没有理由让他等待 60 秒）。此外，没有理由在循环中进行（例如，如果我在循环中执行此操作，在最坏的情况下会像 5 x 60 秒）。

Answer 1

也许通过让主线程休眠？

def do_stuff
  threads = []
  valid_answer = nil

  1.upto(10) do |i|
    threads << Thread.new do
      sleep(rand(3))
      valid_answer ||= i if i > 7
    end
  end

  sleep 0.1 while valid_answer.nil?
  threads.each { |t| t.kill if t.alive? }
  valid_answer
end

编辑：唤醒也有更好的方法：

def do_stuff
  threads = []
  answer = nil

  1.upto(10) do |i|
    threads << Thread.new do
      sleep(rand(3))
      answer ||= i and Thread.main.wakeup if i > 7
    end
  end

  sleep
  threads.each { |t| t.kill if t.alive? }
  answer
end