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

我有一个关于Nodejs光纤的问题（这对我来说是全新的）。。。我有这个Nodejs光纤教程，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代码中发生了什么吗？提前感谢。。。

示例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的回调。然而，上面的代码也会给出一个错误（说明光纤已经在运行）。在分析执行顺序时，人们可能很容易理解原因。

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

这段代码的结构是正确的，但它假设sample是某种异步函数，不会立即调用回调。让我们把你的sample函数换成这个：

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

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

设置指向当前运行光纤的fiber
调用sample，返回时不调用回调
调用`Fiber.yield（），它会"暂停"当前光纤
500毫秒后，调用回调
调用fiber.run()，传递"此回调"，恢复光纤
Fiber.yield返回，将str设置为"this callback"
将字符串记录到控制台

请注意，步骤4是在光纤执行之外完成的。

示例2

而在第一个示例中没有运行的光纤（因此fiber是未定义），在第二个示例中，由于相同的原因引发错误。同样，代码需要在光纤中运行。

产量和运行的函数

一个光纤必须协同地将控制权交给另一个光纤（或执行的主线）。将其与线程和进程的抢占性质进行比较。放弃控制是指"屈服控制"，在这种情况下由Fiber.yield()完成。

要继续执行（直接在光纤屈服点之后），必须在光纤上调用run()。

将值传入和传出光纤的机制是通过产量和运行的相互作用：

yield（光纤内部）返回给run（光纤外部）的自变量
给yield（光纤内部）的自变量由run（光纤外部）返回

举个例子，看看节点光纤github存储库上的增量生成器。此外，请注意，在我们的示例1中，给sample的回调基本上在光纤外部运行，因为它在下一个刻度上运行（即setTimeout的异步特性）。

正如Andrew所解释的，正如我的博客文章中所暗示的（请参阅示例后面的句子），您必须创建一个Fiber并使用run()运行它才能调用Fiber.yield。

当您有一个异步调用要运行时，光纤的好处并不明显，但考虑一下函数f1调用f2调用f3的情况。如果f3用回调调用一个低级异步函数，而如果不使用光纤，则必须将f3变成一个带回调的异步函数，然后通过传染，还必须将f2和f1变成异步函数。使用光纤，可以将f1、f2和f3保持为正常函数（无回调）。您需要在f3内部使用一些Fiber.yield()魔法，还需要从Fiber内部调用f1，但您不需要担心f1和f2主体中的回调。

因此，当您的高级函数和它们调用的低级异步函数之间有多层代码或复杂的控制流时，光纤真的会发光。

此外，编写fiber的Marcel建议您不要在代码中直接使用Fiber.yield()，而是使用他的future库。玩Fiber.yield来了解纤维是由什么组成的很有趣，但我鼓励您在实际项目中使用future库。它还将帮助您并行化代码。

示例1

示例2

产量和运行的函数

相关内容

最新更新

热门标签：