em内的光纤:连接(em-synchrony)

Question

谁能解释一下为什么Redis (redis-rb)同步驱动直接在EM.synchrony块下工作，而不是在EM:Connection下工作？

考虑以下示例

    EM.synchrony do
        redis = Redis.new(:path => "/usr/local/var/redis.sock")

        id = redis.incr "local:id_counter"
        puts id 

        EM.start_server('0.0.0.0', 9999) do |c|
            def c.receive_data(data)
                redis = Redis.new(:path => "/usr/local/var/redis.sock")
                puts redis.incr "local:id_counter"
            end
        end

    end

我得到了

can't yield from root fiber (FiberError)

在receive_data中使用时。通过阅读EventMachine和em-synchrony的源代码，我找不出其中的区别。

谢谢!

PS:显而易见的解决办法是将redis代码包装在EventMachine::Synchrony.next_tick中，就像在issue #59中所暗示的那样，但是考虑到EM.synchrony，我希望已经将调用包装在Fiber中……

PPS:同样适用于使用EM::Synchrony::Iterator

Answer 1

你在这里做了一些相当棘手的事情。您向start_server提供了一个块，它有效地创建了一个“匿名”连接类，并在该类的post_init方法中执行您的块。然后在这个类中定义一个实例方法。

要记住的是:当反应器执行一个回调，或者像receive_data这样的方法时，这会发生在主线程上(以及根纤程中)，这就是为什么你会看到这个异常。要解决这个问题，您需要将每个要执行的回调包装在一个纤程中(例如，请参阅Synchrony.add_(周期性)_timer方法)。

要解决实际的异常:将receive_data的执行包装在纤程中。外部EM.synchrony {}不会对稍后由反应器调度的回调做任何事情。