如何编写一个 Resque 条件来表示“如果进程运行时间超过 n 秒，则终止它”？

Question

我有一个跨越几个工作服务器的 god/resque 设置。有时，工作人员会因长轮询连接而陷入困境，并且无法正确超时。我们已经尝试围绕它进行编码（但无论为什么它不起作用），通过线路发送的保持活动数据包不会让我们轻易超时。

我希望某些工作人员（我已经在他们自己的监视块中分割出来）不允许运行超过一定时间。在 pesudocode 中，我正在寻找如下所示的监视条件（即，如果完成任务所需的时间超过 60 秒，则重新启动该工作程序）：

w.transition(:up, :restart) do |on|
  on.condition(:process_timer) do {|c|  c.greater_than = 60.seconds}
end

对于如何完成此任务的任何想法或指示，我们将不胜感激。

Answer 1

require 'timeout'
Timeout::timeout(60) do
  ...
end

Answer 2

虽然你有一个答案，但我会把它放在这里，因为我已经做到了：

class TimedThread
  def initialize(limit, &block)
    @thread = Thread.new{ block.call }
    @start = Time.now
    Thread.new do
      while @thread.alive?
        if Time.now - @start > limit
          @thread.kill
          puts "Thread killed"
        end
      end
    end.join
  end
end

[1, 2, 3].each_with_index do |secs, i|
  TimedThread.new(2.5){ sleep secs ; puts "Finished with #{i+1}" }
end

Answer 3

事实证明，在一些示例 resque 文件中有一个如何执行此操作的示例。这并不完全是我想要的，因为它没有添加 on.condition(:foo)，但它是一个可行的解决方案：

# This will ride alongside god and kill any rogue stale worker
# processes. Their sacrifice is for the greater good.

WORKER_TIMEOUT = 60 * 10 # 10 minutes

Thread.new do
  loop do
    begin
      `ps -e -o pid,command | grep [r]esque`.split("\n").each do |line|
        parts   = line.split(' ')
        next if parts[-2] != "at"
        started = parts[-1].to_i
        elapsed = Time.now - Time.at(started)

        if elapsed >= WORKER_TIMEOUT
          ::Process.kill('USR1', parts[0].to_i)
        end
      end
    rescue
      # don't die because of stupid exceptions
      nil
    end

    # Sleep so we don't run too frequently
    sleep 30
  end
end

Answer 4

也许看看resque-restriction？它似乎没有得到积极维护，但可能会满足您的需要。