是Node.js的原生承诺。所有的处理是并行的还是顺序的?

我想澄清这一点，因为文件不是很清楚;

Q1: Promise.all(iterable)是按顺序还是并行处理所有的promise ?或者，更具体地说，它相当于运行链式承诺

p1.then(p2).then(p3).then(p4).then(p5)....

或者它是某种其他类型的算法，其中所有的p1, p2, p3, p4, p5等同时(并行)被调用，并且结果在所有解决(或一个拒绝)后立即返回?

问题2:如果承诺。所有的运行都是并行的，是否有一种方便的方法来运行一个可迭代对象?

注意:我不想使用Q或蓝鸟，而是所有本地ES6规格。

当前回答

Bergi的回答让我使用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。因此，您应该传入不带括号的函数名!现在，我的函数需要一个参数，所以我需要封装在一个匿名函数中，不带参数!

2017-02-06 09:47:53

其他回答

我一直在用for来求解连续的承诺。我不确定这是否有帮助，但这就是我一直在做的。

async function run() {
    for (let val of arr) {
        const res = await someQuery(val)
        console.log(val)
    }
}

run().then().catch()

2017-09-07 16:22:19

并行

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

优点:速度更快。所有的迭代都将启动，即使其中一个在以后失败。然而，它会“快速失败”。使用的承诺。allsettle，即使某些迭代失败，也要并行地完成所有迭代。从技术上讲，这些是并发调用，而不是并行调用。

按顺序

for (const item of items) {
  await fetchItem(item)
}

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

2017-09-07 00:15:32

请看这个示例

的承诺。全部并行工作

const { range, random, forEach, delay} = require("lodash");  
const run = id => {
    console.log(`Start Task ${id}`);
    let prom = new Promise((resolve, reject) => {
        delay(() => {
            console.log(`Finish Task ${id}`);
            resolve(id);
        }, random(2000, 15000));
    });
    return prom;
}


const exec = () => {
    let proms = []; 
    forEach(range(1,10), (id,index) => {
        proms.push(run(id));
    });
    let allPromis = Promise.all(proms); 
    allPromis.then(
        res => { 
            forEach(res, v => console.log(v));
        }
    );
}

exec();

2021-02-08 07:03:35

也可以使用递归函数用异步函数顺序处理可迭代对象。例如，给定一个数组a，使用异步函数someAsyncFunction()处理:

var a = [1, 2, 3, 4, 5, 6] function someAsyncFunction(n) { return new Promise((resolve, reject) => { setTimeout(() => { console.log("someAsyncFunction: ", n) resolve(n) }, Math.random() * 1500) }) } //You can run each array sequentially with: function sequential(arr, index = 0) { if (index >= arr.length) return Promise.resolve() return someAsyncFunction(arr[index]) .then(r => { console.log("got value: ", r) return sequential(arr, index + 1) }) } sequential(a).then(() => console.log("done"))

2017-08-17 02:48:21