Node.js本机Promise.all是并行还是顺序处理？

Question

我想澄清这一点，因为文档对此不太清楚。问题1：是Promise.all(iterable)按顺序还是并行处理所有承诺？或者，更具体地说，它相当于运行像p1.then(p2).then(p3).then(p4).then(p5)....或者是一些其他类型的算法的所有p1，p2，p3，p4，p5，等是被称为在同一时间（并行）和结果尽快返回所有的决心（或一个不合格品）？问题2：如果Promise.all并行运行，是否有一种方便的方法可以依次运行可迭代程序？注意：我不想使用Q或Bluebird，而是要使用所有本机ES6规范。

Answer 1

正在Promise.all(iterable)执行的所有承诺？

不，诺言不能“被执行”。它们在创建时就开始执行任务-它们仅代表结果-并且您在并行执行所有操作之前甚至将其传递给它们Promise.all。

Promise.all只会等待多个承诺。它不在乎它们以什么顺序解析，也不管计算是否并行运行。

是否有一种方便的方法来依次运行迭代？

如果您已经有了承诺，那么您将无能为力，但是Promise.all([p1, p2, p3, …])（没有顺序的概念）。但是，如果您确实具有可迭代的异步函数，则实际上可以按顺序运行它们。基本上你需要从

[fn1, fn2, fn3, …]

至

fn1().then(fn2).then(fn3).then(…)

解决此问题的方法是使用Array::reduce：

iterable.reduce((p, fn) => p.then(fn), Promise.resolve())

Answer 2

在平行下

await Promise.all(items.map(async item => { await fetchItem(item) }))

优点：更快。即使一次迭代失败，也将执行所有迭代。

按顺序

for (let i = 0; i < items.length; i++) {

    await fetchItem(items[i])

}

优点：循环中的变量可以由每次迭代共享。行为类似于普通的命令式同步代码。

Answer 3

Bergis的答案使用Array.reduce使我走上了正确的轨道。

但是，要使函数真正返回我的诺言，一个接一个地执行，我必须添加一些嵌套。

我的实际用例是由于下游限制而需要依次传输的一系列文件...

这就是我最后得到的。

getAllFiles().then( (files) => {

    return files.reduce((p, theFile) => {

        return p.then(() => {

            return transferFile(theFile); //function returns a promise

        });

    }, Promise.resolve()).then(()=>{

        console.log("All files transferred");

    });

}).catch((error)=>{

    console.log(error);

});

如先前的答案所示，请使用：

getAllFiles().then( (files) => {

    return files.reduce((p, theFile) => {

        return p.then(transferFile(theFile));

    }, Promise.resolve()).then(()=>{

        console.log("All files transferred");

    });

}).catch((error)=>{

    console.log(error);

});

在开始另一个文件传输之前没有等待传输完成，甚至在开始第一个文件传输之前就出现了“已传输所有文件”文本。

不知道我做错了什么，但想分享对我有用的东西。

编辑：自从我写了这篇文章后，我现在了解了为什么第一个版本不起作用。then（）期望一个函数返回一个promise。因此，您应该传递不带括号的函数名称！现在，我的函数需要一个参数，因此我需要包装成不带参数的匿名函数！