在EventMachine循环外部发送

Question

我使用的是emws客户端gem，尽管我认为我的问题比这更一般。我试图从EventMachine接收块外部发送数据，但要发送数据需要很长时间（~20秒）：

require "em-ws-client"

m = Mutex.new
c = ConditionVariable.new

Thread.new do
  EM.run do
    @ws = EM::WebSocketClient.new("ws://echo.websocket.org")

    @ws.onopen do
      puts "connected"
      m.synchronize { c.broadcast }
    end

    @ws.onmessage do |msg, binary|
      puts msg
    end
  end
end

m.synchronize { c.wait(m) }

@ws.send_message "test"

sleep 100

当我把@ws。将消息“test”直接发送到onopen方法中，效果很好。我不明白为什么我的版本不起作用。我在EventMachine中发现了这个问题，但我不确定它是否相关。

为什么要花这么长时间，我该怎么解决呢？

Answer 1

事件机器严格是单线程的，不建议在线程之间共享套接字。您可能在这里看到的是一个问题，即主EventMachine线程不知道您已经提交了一个send_message调用，并将其缓存了很长一段时间。

在EventMachine中使用线程时，我会非常非常小心。我看到过，如果遇到线程计时或同步问题，它就会出现故障和崩溃。