我想澄清这一点,因为文件不是很清楚;
Q1: Promise.all(iterable)是按顺序还是并行处理所有的promise ?或者,更具体地说,它相当于运行链式承诺
p1.then(p2).then(p3).then(p4).then(p5)....
或者它是某种其他类型的算法,其中所有的p1, p2, p3, p4, p5等同时(并行)被调用,并且结果在所有解决(或一个拒绝)后立即返回?
问题2:如果承诺。所有的运行都是并行的,是否有一种方便的方法来运行一个可迭代对象?
注意:我不想使用Q或蓝鸟,而是所有本地ES6规格。
NodeJS不是并行运行承诺,而是并发运行,因为它是一个单线程事件循环架构。有可能通过创建一个新的子进程来利用多核CPU来并行运行。
并行Vs并发
其实,什么承诺。所做的就是,将Promise函数堆叠在适当的队列中(参见事件循环架构),并发运行它们(调用P1, P2,…),然后等待每个结果,然后解析Promise。所有的许诺都有结果。
的承诺。所有人都会在第一次承诺时失败,除非你必须自己处理拒绝。
并行和并发有一个很大的区别,第一个会在完全相同的时间在一个单独的进程中运行不同的计算,它们会按照自己的节奏进行,而另一个会一个接一个地执行不同的计算,而不需要等待前一个计算完成并同时进行,而不依赖彼此。
最后,回答你的问题,我保证。所有这些都不是并行或顺序执行,而是并发执行。
是的,您可以按照如下方式链接一个promise返回函数数组
(这将每个函数的结果传递给下一个函数)。当然,您可以编辑它,将相同的参数(或不传递参数)传递给每个函数。
function tester1(a) {
return new Promise(function(done) {
setTimeout(function() {
done(a + 1);
}, 1000);
})
}
function tester2(a) {
return new Promise(function(done) {
setTimeout(function() {
done(a * 5);
}, 1000);
})
}
function promise_chain(args, list, results) {
return new Promise(function(done, errs) {
var fn = list.shift();
if (results === undefined) results = [];
if (typeof fn === 'function') {
fn(args).then(function(result) {
results.push(result);
console.log(result);
promise_chain(result, list, results).then(done);
}, errs);
} else {
done(results);
}
});
}
promise_chain(0, [tester1, tester2, tester1, tester2, tester2]).then(console.log.bind(console), console.error.bind(console));
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。因此,您应该传入不带括号的函数名!现在,我的函数需要一个参数,所以我需要封装在一个匿名函数中,不带参数!
你可以通过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);
}