ruby - 如何在 eventmachine 中实现无限循环

Question

我需要在 eventmachine 之上有一个无限循环，不断读取 redis 队列。下面是我的代码。递归是正确的方法吗？我尝试loop do了循环，但无法使其以这种方式工作。

require 'em-hiredis'

def read
  d = @redis.blpop 'queue', 0
  d.callback do |_, value|
    p value
    read
  end.errback do |e|
    p e
    EM.next_tick { read }
  end
end

EM.run do
  @redis = EM::Hiredis.connect
  read
end

Answer 1

最好订阅 redis 发布/订阅队列。 https://gist.github.com/957367 如果你真的需要一个循环，那么 EM 本身就是一个无限循环，你只需要用 next_tick 一次又一次地安排你的工作：

def read
  d = @redis.blpop 'queue', 0
  d.callback do |_, value|
    EM.next_tick { read }
  end.errback do |e|
    EM.next_tick { read }
  end
 end