node.js - 使用 async/await 逐一读取文件

Question

代码如下:

function readfile(file) {
   var readline = require('readline');
   var fs = require('fs');
   var fReadAD = fs.createReadStream(file,{ encoding: 'utf8'});
   var objReadlineAD = readline.createInterface({
      input: fReadAD
   });
   objReadlineAD.on('close', (line)=>{
      return new Promise(function(){
          console.log('file:'+file)
      });
   });
}
(async () => {
   await readfile('./import/1.xls')
   await readfile('./import/2.csv')
})();

为什么输出是

file:./import/2.csv
file:./import/1.xls

我觉得应该是

file:./import/1.xls
file:./import/2.csv

我在异步中使用了await。有人能告诉我出了什么问题吗？谢谢!

Answer 1

您的返回 new Promise() 未从 readFile() 返回。因为 Node.js 中的异步操作是非阻塞的，所以 readfile() 函数立即返回(没有返回值)，然后文件事件稍后发生(在函数返回之后)。因此，您的 readFile() 函数不会返回任何内容，因此await 无法 promise 实际等待。

这表明您需要一些有关异步事件和操作在 Node.js 中如何工作的基础教育/阅读。

您所做的return new Promise()只是返回到readLine库文件系统事件处理代码并被忽略，因此它不会做任何有用的事情。它实际上并没有返回给任何寻求 promise 的人。

因此，由于您实际上没有返回任何内容，并且实际上没有等待任何内容，因此两个异步操作并行进行，并且不确定哪个操作先完成。这可能取决于每个 readFile() 需要多长时间的详细信息，这只是一场竞赛，看哪一个先完成。你没有控制它们的执行顺序。

事件的顺序是这样的:

1. 开始第一个readFile()操作。它不返回任何返回值，并且其中的文件操作作为异步代码/事件进行。
2. 您等待未定义，它不会等待任何东西。
3. 开始第二个readFile()操作。它不返回任何返回值，并且其中的文件操作作为异步代码/事件进行。
4. 您等待未定义，它不会等待任何东西。
5. 两个 readFile() 操作之一生成其关闭事件(以先完成者为准)。
6. 其他 readFile() 操作生成其关闭事件。

您可以让 readFile() 实际上返回一个在完成时连接到的 Promise，然后您可以像这样 await :

const fs = require('fs');
const readline = require('readline');

function readfile(file) {
   return new Promise(function(resolve, reject) {
       var fReadAD = fs.createReadStream(file,{ encoding: 'utf8'});
       var objReadlineAD = readline.createInterface({
          input: fReadAD
       });
       objReadlineAD.on('close', () => {
           console.log('file:'+file)
           resolve();
       }).on('error', reject);
   });
}

(async () => {
   await readfile('./import/1.xls')
   await readfile('./import/2.csv')
})();