基于事件的读取功能会出现故障吗？

Question

假设我使用 nodejs readline 库遍历 STDIN 流中的每一行，对其进行一些处理并将其写回 STDOUT，如下例所示：

var rl = readline.createInterface({
  input: process.stdin,
  output: process.stdout,
  terminal: false
});
function my_function(line) {
    var output = ...(line);
    process.stdout.write(output);
}
rl.on('line', my_function);

我担心我正在执行的处理将花费非常不同的时间，具体取决于行内容，因此有些行会很快返回，而另一些则需要一些时间来整理。 my_function() 是否有可能出现故障并因此导致输出流被打乱？我应该考虑使用某种同步循环而不是这个异步事件处理程序吗？

Answer 1

JavaScript 执行本身是单线程的，所以只要你只是在事件处理程序内部执行同步操作，就没有问题。

如果您正在在事件处理程序中执行异步操作，那么在您的异步操作完成之前可能会发出另一个'line'事件.在这种情况下，您需要先rl.pause()，然后在完成异步操作后rl.resume()。但是，这并不是万无一失的，因为如果从输入流中读取的当前数据块有多个换行符，rl.pause() 之后仍然可以发出 'line' 事件。

因此，如果您在事件处理程序中执行异步操作，您最好自己从流中读取，以便更好地控制解析行为。这实际上很容易做到，例如：

function parseStream(stream, callback) {
  // Assuming all stream data is text and not binary ...
  var buffer = '';

  var RE_EOL = /\r?\n/g;

  stream.on('data', function(data) {
    buffer += data;
    processBuffer();
  });

  stream.on('end', callback);

  stream.on('error', callback);

  function processBuffer() {
    var idx = RE_EOL.exec(buffer);
    if (~idx) {
      // Found a line ending

      var line = buffer.slice(0, RE_EOL.index);
      buffer = buffer.slice(RE_EOL.index + RE_EOL[0].length);

      stream.pause();
      callback(null, line, processBuffer);
    } else {
      stream.resume();
    }
  }
}

// ...

processStream(process.stdin, function(err, line, done) {
  if (err) throw err;

  if (line === undefined) {
    // No more data will be available (stream ended)
    console.log('(Stream ended!)');
    return;
  }

  // Do something with `line`
  console.log(line);

  // Call `done()` whenever your async operation(s) are all finished
  done();
});