FileStream Promise 尽早解决

Question

我在 nodeJS 中遇到了一个相当奇怪的问题，我不知道为什么。

考虑以下代码：

(async () => {
    console.log ("1");

    await new Promise ((resolve, reject) => {
        setTimeout (() => {
            console.log ("2");
            resolve ();
        }, 1000);
    });

    console.log ("3");
    process.exit ();
})();

这段代码完全按照它应该做的。它按该顺序打印123。在打印1 之后，它会等待大约一秒钟。完美的。现在让我们看下面的例子：

const fs = require ("fs");

(async () => {
    const stream = fs.createWriteStream ("file.txt");
    stream.write ("Test");

    console.log ("1");

    await new Promise ((resolve, reject) => {
        stream.on ("finish", () => {
            console.log ("2");
            resolve ();
        });
    });

    console.log ("3");
    process.exit ();
})();

据我了解，此代码应该完成，或者 - 如果 finish 事件永远不会被触发 - 无限运行。发生的情况正好相反：它打印1，然后退出。它不应该至少在退出之前打印另一个3，因为这是脚本的结尾吗？

重要：我知道承诺不会解决，因为.end() 没有在流上调用。我想知道为什么脚本还是完成了。

谁能向我解释这种行为？

Answer 1

最好的解释可能是在不使用 async/await 关键字的情况下编写此代码，以便您了解这些不会做任何“神奇”的事情，而只是“糖”，以不同的方式解决 Promise，而不是 @987654323 @。

const fs = require ("mz/fs");

const stream = fs.createWriteStream("file.txt");
stream.write("Test");

console.log("1");

new Promise ((resolve, reject) => {
    stream.on ("finish", () => {
        console.log("2");
        resolve();
    });
}).then(() => {
   console.log("2");
   process.exit();
});

这完全一样！那么问题在哪里。

您真正缺少的是，当您打开文件句柄时，“没有任何东西”表明它“必须”在程序退出之前显式关闭。因此，“无需等待”，程序完成但不会“分支”到仍在等待 Promise 到 resolve() 的部分。

它只记录 "1" 的原因是因为剩余的分支“正在”等待 Promise 解决，但在程序完成之前它永远不会到达那里。

当然，当您在 write 之后立即实际调用 stream.end() 或理想情况下通过“等待”任何可能挂起的写入请求时，所有这些都会发生变化：

const fs = require ("mz/fs");

(async () => {
    const stream = fs.createWriteStream ("file.txt");
    await stream.write ("Test");          // await here before continuing
    stream.end()
    console.log ("1");

    await new Promise ((resolve, reject) => {
        stream.on ("finish", () => {
            console.log ("2");
            //resolve ();
        });
    });

    console.log ("3");
    //process.exit ();
})();

这当然会记录列表中的每个输出，您应该很清楚。

所以，如果您希望在日志中看到 "3"，原因是 await 我们从不关闭流。摆脱await：

const fs = require ("mz/fs");

(async () => {
    const stream = fs.createWriteStream ("file.txt");
    await stream.write ("Test");
    stream.end()
    console.log ("1");

    new Promise ((resolve, reject) => {    // remove await - execution hoisted
        stream.on ("finish", () => {
            console.log ("2");
            //resolve ();
        });
    });

    console.log ("3");
    //process.exit ();
})();

那么你“应该”看到：

1
3
2

至少在大多数系统上，除非您有“极端”滞后。但一般来说，"finish" 应该在“等待”write 之后到达下一行之前被解雇。

---

注意：这里只使用mz 库来演示write() 方法上的await，而不包装回调。一般来说，回调执行应该解决同样的问题。