Ruby 2.4

Fiber

class 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 }