我想澄清这一点，因为文件不是很清楚;
Q1: Promise.all(iterable)是按顺序还是并行处理所有的promise ?或者，更具体地说，它相当于运行链式承诺
p1.then(p2).then(p3).then(p4).then(p5)....
或者它是某种其他类型的算法，其中所有的p1, p2, p3, p4, p5等同时(并行)被调用，并且结果在所有解决(或一个拒绝)后立即返回?
问题2:如果承诺。所有的运行都是并行的，是否有一种方便的方法来运行一个可迭代对象?
注意:我不想使用Q或蓝鸟，而是所有本地ES6规格。
当前回答
我一直在用for来求解连续的承诺。我不确定这是否有帮助，但这就是我一直在做的。
async function run() {
for (let val of arr) {
const res = await someQuery(val)
console.log(val)
}
}
run().then().catch()
其他回答
我一直在用for来求解连续的承诺。我不确定这是否有帮助，但这就是我一直在做的。
async function run() {
for (let val of arr) {
const res = await someQuery(val)
console.log(val)
}
}
run().then().catch()
只是详细阐述一下@Bergi的回答(非常简洁，但很难理解;)
这段代码将运行数组中的每一项，并将下一个'then chain'添加到末尾:
function eachorder(prev,order) {
return prev.then(function() {
return get_order(order)
.then(check_order)
.then(update_order);
});
}
orderArray.reduce(eachorder,Promise.resolve());
NodeJS不是并行运行承诺，而是并发运行，因为它是一个单线程事件循环架构。有可能通过创建一个新的子进程来利用多核CPU来并行运行。
并行Vs并发
其实，什么承诺。所做的就是，将Promise函数堆叠在适当的队列中(参见事件循环架构)，并发运行它们(调用P1, P2，…)，然后等待每个结果，然后解析Promise。所有的许诺都有结果。 的承诺。所有人都会在第一次承诺时失败，除非你必须自己处理拒绝。
并行和并发有一个很大的区别，第一个会在完全相同的时间在一个单独的进程中运行不同的计算，它们会按照自己的节奏进行，而另一个会一个接一个地执行不同的计算，而不需要等待前一个计算完成并同时进行，而不依赖彼此。
最后，回答你的问题，我保证。所有这些都不是并行或顺序执行，而是并发执行。
也可以使用递归函数用异步函数顺序处理可迭代对象。例如，给定一个数组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"))
请看这个示例
的承诺。全部并行工作
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();
