javascript - node.js 中的信号量 - 使用计数器变量

Question

我研究 JavaScript 已经有一段时间了，我似乎无法理解为什么下面的代码不起作用。我尝试使用类似信号量的技术让主执行线等待异步函数调用结束。您可以在此处查看代码:

var fs = require("fs");
var data = "";
var asyncDone = false;
var fstream = fs.createReadStream("text.txt");
fstream.setEncoding("utf-8");

fstream.on("data", function (chunk) {
    data += chunk;
});
fstream.on("end", function() {
    console.log("reading done");
    console.log(data);
    asyncDone = true;
});

while (! asyncDone) { }
console.log("program terminating");

如有任何帮助，我们将不胜感激。

Answer 1

问题是对event loop.的误解

简而言之，JavaScript 有一个事件队列，所有异步事件都放在其中。只要 JS 引擎当前不忙，即当前没有代码正在执行，它就会从事件队列中提取下一个事件。

您的异步处理程序已被推送到事件队列，但您的 while 循环阻止执行永远结束，因此引擎永远没有机会运行队列中的下一个事件。

一种想象方式是这样的:

var eventQueue = [];
function addToQueue(f) {
  eventQueue.push(f);
}
function runNext() {
  if (eventQueue.length) {
    var f = eventQueue.shift();
    f();
    runNext();
  }
}    

addToQueue(function() {
  // Note that in reality the binding occurs synchronously,
  // it's just that the callback will occur asynchronously
  fstream.on('data', function(chunk) {
    // ...
  });
});

while (!asyncDone) { }
runNext();