javascript - 如何使用 Node.js Fibers 运行代码

Question

我有一个关于 Nodejs Fibers 的问题(这对我来说绝对是新的)...我有这个 Nodejs Fibers 教程，http://bjouhier.wordpress.com/2012/03/11/fibers-and-threads-in-node-js-what-for/ ，这里有一个例子

    var fiber = Fiber.current;
    db.connect(function(err, conn) {
    if (err) return fiber.throwInto(err);
       fiber.run(conn);
    });
   // Next line will yield until fiber.throwInto 
   // or fiber.run are called
   var c = Fiber.yield();
   // If fiber.throwInto was called we don't reach this point 
   // because the previous line throws.
   // So we only get here if fiber.run was called and then 
   // c receives the conn value.
   doSomething(c);
   // Problem solved! 

现在基于这个示例，我创建了自己的代码版本，如下所示，

  var Fiber = require('fibers');

  function sample(callback){
     callback("this callback");
  }

  var fiber = Fiber.current;
  sample(function(string){
     fiber.run(string);
  });
  var string = Fiber.yield();
  console.log(string);

但这给了我一个错误，

/home/ubuntu/Tasks/ServerFilteringV1/test.js:28
    fiber.run(string);
      ^
TypeError: Cannot call method 'run' of undefined

我还有另一种情况，它会在 1000 毫秒后运行一个带有回调的函数(我这样做是为了测试回调前长时间执行的函数)，

var Fiber = require('fibers');

function forEach(callback){
   setTimeout(function(){
       callback("this callback");
   },1000);
}


var fiber = Fiber.current;
forEach(function(string){
   fiber.run(string);
});
var string = Fiber.yield();
console.log(string);

这里的代码给了我另一个错误，

/home/ubuntu/Tasks/ServerFilteringV1/test.js:30
var string = Fiber.yield();
                    ^
Error: yield() called with no fiber running

那么，yield() 应该在 run() 函数执行后等待吗？知道我的 nodejs 代码中发生了什么吗？提前致谢...

Answer 1

例子1

纤程是一种轻量级的执行线程。与真正的线程和进程一样，必须为纤程提供一段代码以在运行时执行。您从 bjouhier 获取的代码无法正常工作。它旨在在光纤内部运行，如下所示:

var f = Fiber(function() {
    var fiber = Fiber.current;

    sample(function(str) {
        fiber.run(string);
    });

    var str = Fiber.yield();
    console.log(str);
});

f.run();

调用 run在光纤上，运行光纤代码，它作为对 Fiber 的回调给出。 .然而，上面的代码也会报错(说明光纤已经在运行)。分析执行顺序时可能很容易看出原因。

1. 设置变量f作为纤维。
2. 运行 纤程:
   1. 设置变量fiber指向当前运行的光纤。
   2. 调用函数sample .
   3. 调用回调。
   4. 调用 fiber.run ，由于当前纤程已在运行，因此会出现错误。

这段代码的结构是正确的，但它假设sample是一些不立即调用回调的异步函数。让我们换掉你的 sample通过这个功能:

function sample(callback) {
    setTimeout(function() {
        callback("this callback");
    }, 500);
}

现在，上面的代码不会发出错误，因为 sample立即返回。纤程内部的执行顺序是:

1. 设置 fiber指向当前运行的光纤。
2. 调用 sample ，它在不调用回调的情况下返回(尚未)。
3. 调用 `Fiber.yield()，它会“暂停”当前的光纤。
4. 500 毫秒后，调用回调。
5. 调用 fiber.run()传递“此回调”，恢复光纤。
6. Fiber.yield返回，设置 str 为'this callback'。
7. 记录到控制台的字符串。

观察第 4 步是在纤程执行之外完成的。

例子2

虽然在第一个示例中没有正在运行的光纤(因此 fiber 是未定义)，但在第二个示例中，出于同样的原因抛出错误。同样，代码需要在纤程内运行。

---

yield和run的作用

一个纤程必须合作将控制权交给另一个纤程(或执行的主线)。将其与线程和进程的抢占性质进行比较。放弃控制就是“屈服控制”的意思，在这种情况下是由Fiber.yield()完成的。 .

要继续执行(紧接纤维产生的点之后)，必须调用 run()在纤维上。

将值传入和传出纤程的机制是通过 yield 和 run 的相互作用:

• 给 run 的一个参数(在光纤之外)，由 yield 返回(在纤维内部)。
• 给 yield 的一个参数(在纤维内部)，由 run 返回(纤维外)。

例如，查看 the github repository of node-fibers 上的增量生成器.此外，请注意我们的示例 1，给 sample 的回调本质上是在 光纤之外运行，因为它在下一个 tick 上运行(即 setTimeout 的异步性质)。