Fiber

Parent:Object

Fibers是在Ruby中实现轻量级协同并发的原始语言。基本上，它们是创建可以暂停和恢复的代码块的手段，非常类似于线程。主要区别在于它们永远不会被抢占，调度必须由程序员而不是VM来完成。

与其他无堆栈轻量级并发模型相反，每个fiber都附带一个堆栈。这可以使fiber在fiber模块内从深度嵌套的函数调用中暂停。请参阅ruby（1）手册页以配置fiber堆栈的大小。

fiber创建时不会自动运行。相反，必须明确要求使用该Fiber#resume方法运行。在fiber内运行的代码可以通过调用来放弃控制，Fiber.yield在这种情况下，它将控制返回给调用者（调用者Fiber#resume）。

一旦产生或终止，fiber返回最后执行的表达式的值

例如：

fiber = Fiber.new do
  Fiber.yield 1
  2
end

puts fiber.resume
puts fiber.resume
puts fiber.resume

产生结果：

1
2
FiberError: dead fiber called

该Fiber#resume方法接受任意数量的参数，如果它是第一次调用，resume那么它们将作为块参数传递。否则，它们将成为呼叫的返回值Fiber.yield

例子：

fiber = Fiber.new do |first|
  second = Fiber.yield first + 2
end

puts fiber.resume 10
puts fiber.resume 14
puts fiber.resume 18

产生结果：

12
14
FiberError: dead fiber called

公共类方法

current() → fiber Show source

返回当前fiber。您需要require 'fiber'在使用此方法之前。如果您未在fiber环境中运行，则此方法将返回根fiber。

static VALUE
rb_fiber_s_current(VALUE klass)
{
    return rb_fiber_current();
}

yield(args, ...) → obj Show source

控制返回到恢复fiber的上下文，传递传递给它的任何参数。resume下一次调用fiber时，fiber将恢复处理。传递给下一个参数的任何参数resume都将是该Fiber.yield表达式计算的值。

static VALUE
rb_fiber_s_yield(int argc, VALUE *argv, VALUE klass)
{
    return rb_fiber_yield(argc, argv);
}

公共实例方法

alive? → true or false Show source

如果fiber仍然可以恢复（或转移到），则返回true。完成fiber模块的执行后，此方法将始终返回false。您需要require 'fiber'在使用此方法之前。

VALUE
rb_fiber_alive_p(VALUE fibval)
{
    rb_fiber_t *fib;
    GetFiberPtr(fibval, fib);
    return fib->status != TERMINATED ? Qtrue : Qfalse;
}

resume(args, ...) → obj Show source

从最后一个Fiber.yield被调用的位置恢复fiber，或者在第一个要恢复的调用时开始运行fiber。传递给继续的参数将是Fiber.yield表达式的值，或者如果这是第一个resume，它将作为块参数传递给光纤块。

或者，在调用resume时，它将评估传递给Fiber.yieldfiber块内下一个语句的参数，或者如果运行到完成而没有任何参数，则返回块值Fiber.yield

static VALUE
rb_fiber_m_resume(int argc, VALUE *argv, VALUE fib)
{
    return rb_fiber_resume(fib, argc, argv);
}

transfer(args, ...) → obj Show source

将控制转移到其他fiber，从上次停止的地方恢复，或者在之前未恢复的情况下启动。呼叫fiber将被挂起，就像在打电话一样Fiber.yield。在使用此方法之前，您需要require 'fiber'。

接到转接电话的fiber被视为很像简历电话。传递给转移的参数与传递给继承的参数一样。

您无法恢复将控制权转交给另一个控制权的fiber。这会导致双重恢复错误。您需要将控制权交还给这个fiber，然后才能恢复。

例子：

fiber1 = Fiber.new do
  puts "In Fiber 1"
  Fiber.yield
end

fiber2 = Fiber.new do
  puts "In Fiber 2"
  fiber1.transfer
  puts "Never see this message"
end

fiber3 = Fiber.new do
  puts "In Fiber 3"
end

fiber2.resume
fiber3.resume

产生结果：

In fiber 2
In fiber 1
In fiber 3

static VALUE
rb_fiber_m_transfer(int argc, VALUE *argv, VALUE fibval)
{
    rb_fiber_t *fib;
    GetFiberPtr(fibval, fib);
    fib->transferred = 1;
    return fiber_switch(fib, argc, argv, 0);
}

本文档系腾讯云开发者社区成员共同维护，如有问题请联系 cloudcommunity@tencent.com

最后更新于：2017-12-18