3

我是纤维和 EventMachine 的新手，直到最近我在查看 Ruby 是否具有任何并发​​功能（如 go-lang）时才发现纤维。

对于使用 Fiber 的实际用例，似乎没有很多示例。

我确实设法找到了这个：https ://www.igvita.com/2009/05/13/fibers-cooperative-scheduling-in-ruby/ （从 2009 年回来！！！）

其中有以下代码：

require 'eventmachine'
require 'em-http'
require 'fiber'

def async_fetch(url)
  f = Fiber.current
  http = EventMachine::HttpRequest.new(url).get :timeout => 10
  http.callback { f.resume(http) }
  http.errback { f.resume(http) }

  return Fiber.yield
end

EventMachine.run do
  Fiber.new{
    puts "Setting up HTTP request #1"
    data = async_fetch('http://www.google.com/')
    puts "Fetched page #1: #{data.response_header.status}"

    EventMachine.stop
  }.resume
end

这很棒，异步 GET 请求！耶！！！但是......我实际上如何异步使用它？除了创建包含 Fiber 之外，该示例没有任何内容。

据我了解（并且不了解）：

async_fetch 在调用 f.resume 之前一直处于阻塞状态。

f 是当前的 Fiber，它是在 EventMachine.run 块中创建的包装 Fiber。

async_fetch 将控制流返回给它的调用者？我不确定这是做什么的

为什么包覆光纤最后有恢复？光纤是否默认暂停？

在示例之外，我如何使用纤程来表示，发出一堆由键盘命令触发的请求？

例如：每次我输入一封信时，我都会向谷歌提出请求或其他什么？- 通常这需要一个线程，主线程会告诉并行线程为每个请求启动一个线程。:-\

我是并发/纤维的新手。但他们是如此有趣！

如果有人能回答这些问题，那将不胜感激！！！

4

1 回答 1

2

Ruby 中的纤维存在很多混淆。Fiber 不是实现并发的工具。它们只是一种组织代码的方式，可以更清楚地代表正在发生的事情。

在我看来，“纤维”这个名字与“线程”相似，这导致了混乱。

如果您想要真正的并发，即在所有可用 CPU 上分配 CPU 负载，您有以下选择：

在 MRI 红宝石

运行多个 Ruby VM（即 OS 进程）、使用 fork 等。即使在 Ruby 中有多个线程，GIL（全局解释器锁）也可以防止 Ruby 运行时使用超过 1 个 CPU。

在 JRuby 中

与 MRI Ruby 不同，JRuby 在分配线程时将使用多个 CPU，因此您可以获得真正的并发处理。

如果您的代码大部分时间都在等待外部资源，那么您可能不需要这种真正的并发性。MRI 线程或某种事件处理循环可能适合您。

于 2016-04-23T07:32:08.403 回答