3

我知道纤维是协作线程。纤程可以控制执行上下文，而抢占式线程则不能。光纤可以产生控制，这意味着光纤可以在明确定义的位置开始和停止。

显然，在事件红宝石中使用纤维的原因是为了清理由反应器模式引起的嵌套块。

但是我很难掌握下面使用光纤的脚本的控制流程。

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

我理解的方式：

1) EM 开始它的事件循环

2）创建一个纤程，然后调用resume。传递给 new 的代码块是立即执行还是在调用 resume 后执行？

3）第一次调用http_get。它执行异步事件（在 linux 上使用 select、poll 或 epoll）。我们设置了异步事件的事件处理程序（在回调方法中）。然后 Fiber 自愿将控制权交给 EventMachine 所在的线程（主线程）。但是，一旦调用回调，它将通过 f.resume(http) 收回控制权。但是在这个简化的例子中，我应该把我自己的回调代码放在 f.resume(http) 之后吗？因为现在看起来 f.resume(http) 只是将控制权返回给光纤，而没有做任何其他事情。

我认为在 yield 之后发生的事情是控件进入 EventMachine 并进入其事件循环。所以第二个 http_get 还没有被调用。现在一旦调用回调，控制权就会返回给 Fiber（我们只使用一个 Fiber.new，所以我假设所有这些中只有一个 Fiber 实例）。但是第二个 http_get 什么时候被调用呢？

4

1 回答 1

1

让我看看能不能为你解答。我正在添加行号以帮助描述：

01: def http_get(url)
02:   f = Fiber.current
03:   http = EventMachine::HttpRequest.new(url).get
04: 
05:   # resume fiber once http call is done
06:   http.callback { f.resume(http) }
07:   http.errback  { f.resume(http) }
08: 
09:   return Fiber.yield
10: end
11: 
12: EventMachine.run do
13:   Fiber.new{
14:     page = http_get('http://www.google.com/')
15:     puts "Fetched page: #{page.response_header.status}"
16: 
17:     if page
18:       page = http_get('http://www.google.com/search?q=eventmachine')
19:       puts "Fetched page 2: #{page.response_header.status}"
20:     end
21:   }.resume
22: end
  1. 第 21 行开始执行 Fiber，其代码在第 14-20 行
  2. Fiber 代码似乎在执行以下操作：第 14 行检查我们是否可以在google.come. 在第 17 行，它检查是否有来自 的有效响应http_get，然后在第 18 行执行下一个请求以搜索字符串eventmachine。
  3. .resume当 Fiber在第 21 行开始执行时，第 14 行被执行，它调用http_get方法。
  4. 第 02 到 07 行设置异步 HTTP GET 请求和回调。
  5. 第 09 行将控制权交还给 EventMachine。
  6. 一段时间后，当第 03 行的异步 HTTP GET 调用异步完成执行并导致第 06 或 07 行的回调之一时，在第 13 行到第 20 行创建的原始 Fiber 重新获得控制权。
  7. 现在 Fiber 从第 15 行恢复执行。第 06/07 行的回调传递了对http对象的引用，该对象现在page在第 14 行被变量引用，随后在第 15 行用于转储 HTTP 请求状态。
  8. 随着 Fiber 继续执行，它会检查是否page为真值，然后继续并http_get再次调用，但使用新的 URL。请注意，if page如果nil第 15 行在page没有检查nil.
  9. 类似的过程重复 - 第 02 到 07 行设置 HTTP GET 调用，第 09 行将控制权交还给 EventMachine。
  10. 一段时间后，调用其中一个回调，并在 Fiber 重新获得控制权时执行第 19 行。
  11. 执行第 19 行后，Fiber 将失效。

希望能澄清这个问题。

至于用额外的逻辑处理 HTTP GET 的响应，我想你可以puts用一些有意义的处理逻辑来代替。在puts这个示例中似乎处理响应和回调主要用于恢复 Fiber。

于 2016-09-17T07:17:03.273 回答