ruby - ruby 纤维程序中的控制流程

Question

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

显然，在事件化 ruby​​ 中使用纤程的原因是为了清理由 react 器模式引起的嵌套 block 。

但是我很难理解下面使用 fiber 的脚本的控制流。

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) 似乎只是将控制权返回给 fiber 而没有做任何其他事情。

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

Answer 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行开始执行第14-20行代码的Fiber
2. Fiber 代码似乎在执行以下操作:第 14 行检查我们是否可以在 google.come 上执行 GET。在第 17 行，它检查是否有来自 http_get 的有效响应，然后，在第 18 行执行下一个请求以搜索字符串 eventmachine。
3. 当第 21 行的 .resume 导致 Fiber 执行开始时，第 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 对象的引用，该对象现在在第 14 行中用变量 page 引用并随后在第 15 行中用于转储 HTTP 请求状态。
8. 随着 Fiber 继续执行，它会检查 page 是否为真值，然后继续并再次调用 http_get，但使用新的 URL。请注意，如果 nil 代码 if page 可能永远不会执行，因为第 15 行会在未检查 的情况下访问 page 的地方被炸毁无。
9. 重复类似的过程 - 第 02 到 07 行设置 HTTP GET 调用，第 09 行将控制权交还给 EventMachine。
10. 一段时间后，调用其中一个回调并在 Fiber 重新获得控制权时执行第 19 行。
11. 执行第19行后，Fiber会死掉。

希望这能澄清问题。

就使用附加逻辑处理 HTTP GET 的响应而言，我想您可以用一些有意义的处理逻辑替换 puts。此示例中的 puts 似乎正在处理响应，回调主要用于恢复 Fiber。