在进行数据库调用的线程中使用 ruby​​ 超时

Question

我正在使用 Ruby 1.9.2。

我有一个正在运行的线程，它定期调用数据库。调用可能会很长，有时（由于各种原因）数据库连接会消失。如果它确实消失了，线程就会默默地永远挂在那里。

所以，我想用超时来处理这一切。问题是，在第二次应该调用超时时（总是第二次），它仍然只是挂起。超时永远不会生效。我知道这个问题存在于 1.8 中，但我被引导相信 timeout.rb 在 1.9 中有效。

t = Thread.new do
  while true do
    sleep SLEEPTIME
    begin
      Timeout::timeout(TIMEOUTTIME) do
        puts "About to do DB stuff, it will hang here on the second timeout"
        db.do_db_stuff()
        process_db_stuff()
      end
    rescue Timeout::Error
      puts "Timed out"
      #handle stuff here
    end
  end
end

知道为什么会发生这种情况以及我能做些什么吗？

Answer 1

一种可能性是您的线程没有挂起，它实际上死亡。您应该执行以下操作来弄清楚发生了什么。在创建工作线程之前添加此内容：

Thread.abort_on_exception = true

当线程内引发从未捕获的异常时，整个进程将终止，您可以看到引发了哪个异常。否则（这是默认情况），您的线程将被终止。

如果这不是问题所在，请继续阅读……

Ruby 的超时实现非常幼稚。它设置一个单独的线程，休眠 n 秒，然后盲目地在原始线程内引发超时异常。

现在，原始代码实际上可能位于 rescue 或 ensure 块的中间。在这样的块中引发异常将默默地中止任何类型的清理代码。这可能会使超时的代码处于不正确的状态。

很难判断这是否正是您的问题，但是看看数据库处理程序如何执行相当多的锁定和异常处理，这可能是很有可能的。 这里有一篇文章更深入地解释了这个问题。

有什么方法可以使用数据库的内置超时处理吗？它可能在较低级别上实现，而不是使用 Ruby 的超时实现。

一个简单的替代方案是在单独的进程中安排数据库调用。每次进行繁重的数据库提升时，您都可以分叉主进程。或者您可以设置一个简单的 cronjob 来执行执行它的脚本。如果您需要与主线程通信，这会稍微困难一些。如果您需要有关哪个选项适合您的需求的建议，请留下更多详细信息。

---

根据您的评论，该线程即将消失。这可能是库或应用程序代码中的错误，您可能无法修复该错误。如果您希望捕获数据库处理代码生成的任意错误并随后重试，可以尝试如下操作：

t = Thread.new do
  loop do
    sleep INTERVAL
    begin
      # Execute database queries and process data
    rescue StandardError
      # Log error or recover from error situation before retrying
    end
  end
end

您还可以在 rescueretry 关键字code> 阻止立即重试，但您可能应该保留一个计数器，以确保当不可恢复的错误不断发生时，您不会意外地无限期地重试。