ruby - 如何使用 Ruby 的 Fibers 实现并行任务？

Question

我是纤程和 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 block 中创建的wrapping Fiber。

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

为什么缠绕的纤维最后会有resume？默认情况下光纤是否暂停？

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

例如:每次我输入一个字母时，我都会向 google 或其他东西发出请求？ - 通常这需要一个线程，主线程会告诉并行线程为每个请求启动一个线程。 :-\

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

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

Answer 1

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

在我看来，“fibers”这个名称类似于“threads”，这造成了混淆。

如果您想要真正的并发性，即将 CPU 负载分配到所有可用的 CPU，您有以下选择:

在 MRI Ruby 中

运行多个 Ruby VM(即操作系统进程)，使用 fork 等。即使在 Ruby 中有多个线程，GIL(全局解释器锁)也会阻止 Ruby 运行时使用超过 1 个 CPU。

在 JRuby 中

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

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