我想澄清这一点，因为文件不是很清楚;
Q1: Promise.all(iterable)是按顺序还是并行处理所有的promise ?或者，更具体地说，它相当于运行链式承诺
p1.then(p2).then(p3).then(p4).then(p5)....
或者它是某种其他类型的算法，其中所有的p1, p2, p3, p4, p5等同时(并行)被调用，并且结果在所有解决(或一个拒绝)后立即返回?
问题2:如果承诺。所有的运行都是并行的，是否有一种方便的方法来运行一个可迭代对象?
注意:我不想使用Q或蓝鸟，而是所有本地ES6规格。
当前回答
平行
请看这个例子
const resolveAfterTimeout = async i => {
return new Promise(resolve => {
console.log("CALLED");
setTimeout(() => {
resolve("RESOLVED", i);
}, 5000);
});
};
const call = async () => {
const res = await Promise.all([
resolveAfterTimeout(1),
resolveAfterTimeout(2),
resolveAfterTimeout(3),
resolveAfterTimeout(4),
resolveAfterTimeout(5),
resolveAfterTimeout(6)
]);
console.log({ res });
};
call();
通过运行代码，它将控制台“CALLED”为所有六个承诺，当他们被解决，它将控制台每6个响应超时后，在同一时间
其他回答
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。因此，您应该传入不带括号的函数名!现在，我的函数需要一个参数，所以我需要封装在一个匿名函数中，不带参数!
只是详细阐述一下@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());
我一直在用for来求解连续的承诺。我不确定这是否有帮助，但这就是我一直在做的。
async function run() {
for (let val of arr) {
const res = await someQuery(val)
console.log(val)
}
}
run().then().catch()
你可以通过for循环来实现。
Async函数返回承诺:
async function createClient(client) {
return await Client.create(client);
}
let clients = [client1, client2, client3];
如果你写下面的代码，那么客户端是并行创建的:
const createdClientsArray = yield Promise.all(clients.map((client) =>
createClient(client);
));
但是如果你想按顺序创建客户端，那么你应该使用for循环:
const createdClientsArray = [];
for(let i = 0; i < clients.length; i++) {
const createdClient = yield createClient(clients[i]);
createdClientsArray.push(createdClient);
}
请看这个示例
的承诺。全部并行工作
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();
