我有一个关于 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 代码中发生了什么吗? 提前致谢...
最佳答案
例子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
作为纤维。 - 运行 纤程:
- 设置变量
fiber
指向当前运行的光纤。 - 调用函数
sample
. - 调用回调。
- 调用
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
是未定义),但在第二个示例中,出于同样的原因抛出错误。同样,代码需要在纤程内运行。
yield和run的作用
一个纤程必须合作将控制权交给另一个纤程(或执行的主线)。将其与线程和进程的抢占性质进行比较。放弃控制就是“屈服控制”的意思,在这种情况下是由Fiber.yield()
完成的。 .
要继续执行(紧接纤维产生的点之后),必须调用 run()
在纤维上。
将值传入和传出纤程的机制是通过 yield 和 run 的相互作用:
- 给
run
的一个参数(在光纤之外),由yield
返回(在纤维内部)。 - 给
yield
的一个参数(在纤维内部),由run
返回(纤维外)。
例如,查看 the github repository of node-fibers 上的增量生成器.此外,请注意我们的示例 1,给 sample
的回调本质上是在 光纤之外运行,因为它在下一个 tick 上运行(即 setTimeout
的异步性质)。
关于javascript - 如何使用 Node.js Fibers 运行代码,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/14854346/