3
的示例代码是从here:请解释背后的逻辑这个红宝石纤维例如
def http_get(url)
f = Fiber.current
http = EventMachine::HttpRequest.new(url).get
# resume fiber once http call is done
http.callback { f.resume(http) }
http.errback { f.resume(http) }
return Fiber.yield
end
EventMachine.run do
Fiber.new{
page = http_get('http://www.google.com/')
puts "Fetched page: #{page.response_header.status}"
if page
page = http_get('http://www.google.com/search?q=eventmachine')
puts "Fetched page 2: #{page.response_header.status}"
end
}.resume
end
所以,在EM运行块的背景下,笔者的创建纤维与resume
立即运行它。但是,我不明白为什么逻辑结构是这样构成的。我的意思是,它采用当前的光纤(在这种情况下应该是在EM运行模块中创建的光纤),它会启动一个可能失败或成功的http请求,并恢复当前的光纤。之后它只在光纤上拨打yield
。自从他打电话以来究竟会发生什么情况?有人可以解释为什么http_get
是这样写的吗?创建
Fiber为什么要暂停?此外,代码停止在'puts“提取页面:#{page.response_header.status}”''直到光纤有机会运行并完成? – Geo
传递给EventMachine – apneadiving
谢谢,现在很明显。既然你有一些EM的经验,你可以快速浏览http://stackoverflow.com/questions/12663944/how-can-i-load-all-the-objects-inside-a-table-and-keep - 事件机器响应?也许你可以发现我做错了什么? – Geo