如何在事件机器中实施无限循环

Question

我需要在事件机器上有一个无限的环路，该环路不断读取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 pub/sub队列。https://gist.github.com/957367如果您确实需要一个循环，那么Em本身就是一个无限的循环，您只需要一遍又一遍地安排您的工作：

：

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