据我所知，在ES7/ES2016中，在代码中放置多个await将类似于用promise链接.then（），这意味着它们将一个接一个地执行，而不是并行执行。例如，我们有以下代码：
await someCall();
await anotherCall();
我是否正确理解只有当someCall（）完成时才会调用另一个otherCall（）？并行调用它们最优雅的方式是什么？
我想在Node中使用它，所以也许有一个异步库的解决方案？
编辑：我对这个问题中提供的解决方案不满意：由于异步生成器中的非并行等待承诺，所以速度变慢，因为它使用生成器，我问的是一个更通用的用例。
当前回答
我投票支持：
await Promise.all([someCall(), anotherCall()]);
请注意，调用函数时，可能会导致意外结果：
// Supposing anotherCall() will trigger a request to create a new User
if (callFirst) {
await someCall();
} else {
await Promise.all([someCall(), anotherCall()]); // --> create new User here
}
但以下始终会触发创建新用户的请求
// Supposing anotherCall() will trigger a request to create a new User
const someResult = someCall();
const anotherResult = anotherCall(); // ->> This always creates new User
if (callFirst) {
await someCall();
} else {
const finalResult = [await someResult, await anotherResult]
}
其他回答
我投票支持：
await Promise.all([someCall(), anotherCall()]);
请注意，调用函数时，可能会导致意外结果：
// Supposing anotherCall() will trigger a request to create a new User
if (callFirst) {
await someCall();
} else {
await Promise.all([someCall(), anotherCall()]); // --> create new User here
}
但以下始终会触发创建新用户的请求
// Supposing anotherCall() will trigger a request to create a new User
const someResult = someCall();
const anotherResult = anotherCall(); // ->> This always creates new User
if (callFirst) {
await someCall();
} else {
const finalResult = [await someResult, await anotherResult]
}
我已经创建了一个要点，测试了一些解决承诺的不同方法，并给出了结果。查看可行的选项可能会有所帮助。
编辑：根据Jin Lee的评论提供内容
// Simple gist to test parallel promise resolution when using async / await
function promiseWait(time) {
return new Promise((resolve, reject) => {
setTimeout(() => {
resolve(true);
}, time);
});
}
async function test() {
return [
await promiseWait(1000),
await promiseWait(5000),
await promiseWait(9000),
await promiseWait(3000),
]
}
async function test2() {
return {
'aa': await promiseWait(1000),
'bb': await promiseWait(5000),
'cc': await promiseWait(9000),
'dd': await promiseWait(3000),
}
}
async function test3() {
return await {
'aa': promiseWait(1000),
'bb': promiseWait(5000),
'cc': promiseWait(9000),
'dd': promiseWait(3000),
}
}
async function test4() {
const p1 = promiseWait(1000);
const p2 = promiseWait(5000);
const p3 = promiseWait(9000);
const p4 = promiseWait(3000);
return {
'aa': await p1,
'bb': await p2,
'cc': await p3,
'dd': await p4,
};
}
async function test5() {
return await Promise.all([
await promiseWait(1000),
await promiseWait(5000),
await promiseWait(9000),
await promiseWait(3000),
]);
}
async function test6() {
return await Promise.all([
promiseWait(1000),
promiseWait(5000),
promiseWait(9000),
promiseWait(3000),
]);
}
async function test7() {
const p1 = promiseWait(1000);
const p2 = promiseWait(5000);
const p3 = promiseWait(9000);
return {
'aa': await p1,
'bb': await p2,
'cc': await p3,
'dd': await promiseWait(3000),
};
}
let start = Date.now();
test().then((res) => {
console.log('Test Done, elapsed', (Date.now() - start) / 1000, res);
start = Date.now();
test2().then((res) => {
console.log('Test2 Done, elapsed', (Date.now() - start) / 1000, res);
start = Date.now();
test3().then((res) => {
console.log('Test3 Done, elapsed', (Date.now() - start) / 1000, res);
start = Date.now();
test4().then((res) => {
console.log('Test4 Done, elapsed', (Date.now() - start) / 1000, res);
start = Date.now();
test5().then((res) => {
console.log('Test5 Done, elapsed', (Date.now() - start) / 1000, res);
start = Date.now();
test6().then((res) => {
console.log('Test6 Done, elapsed', (Date.now() - start) / 1000, res);
});
start = Date.now();
test7().then((res) => {
console.log('Test7 Done, elapsed', (Date.now() - start) / 1000, res);
});
});
});
});
});
});
/*
Test Done, elapsed 18.006 [ true, true, true, true ]
Test2 Done, elapsed 18.009 { aa: true, bb: true, cc: true, dd: true }
Test3 Done, elapsed 0 { aa: Promise { <pending> },
bb: Promise { <pending> },
cc: Promise { <pending> },
dd: Promise { <pending> } }
Test4 Done, elapsed 9 { aa: true, bb: true, cc: true, dd: true }
Test5 Done, elapsed 18.008 [ true, true, true, true ]
Test6 Done, elapsed 9.003 [ true, true, true, true ]
Test7 Done, elapsed 12.007 { aa: true, bb: true, cc: true, dd: true }
*/
await Promise.all（[someCall（），anotherCall（）]）；正如已经提到的那样，它将充当线程围栏（在CUDA这样的并行代码中非常常见），因此它将允许其中的所有承诺在不相互阻止的情况下运行，但将阻止执行继续，直到解决所有问题。
另一种值得分享的方法是Node.js异步，如果任务直接与API调用、I/O操作等有限资源的使用相关联，它还允许您轻松控制通常需要的并发量。
// create a queue object with concurrency 2
var q = async.queue(function(task, callback) {
console.log('Hello ' + task.name);
callback();
}, 2);
// assign a callback
q.drain = function() {
console.log('All items have been processed');
};
// add some items to the queue
q.push({name: 'foo'}, function(err) {
console.log('Finished processing foo');
});
q.push({name: 'bar'}, function (err) {
console.log('Finished processing bar');
});
// add some items to the queue (batch-wise)
q.push([{name: 'baz'},{name: 'bay'},{name: 'bax'}], function(err) {
console.log('Finished processing item');
});
// add some items to the front of the queue
q.unshift({name: 'bar'}, function (err) {
console.log('Finished processing bar');
});
Medium文章自动收录（阅读更多）
TL；博士
对并行函数调用使用Promise.all，当发生错误时，应答行为不正确。
首先，立即执行所有异步调用并获取所有Promise对象。其次，对Promise对象使用await。这样，当您等待第一个Promise来解决其他异步调用时，其他异步调用仍在进行。总的来说，您将只等待最慢的异步调用。例如：
// Begin first call and store promise without waiting
const someResult = someCall();
// Begin second call and store promise without waiting
const anotherResult = anotherCall();
// Now we await for both results, whose async processes have already been started
const finalResult = [await someResult, await anotherResult];
// At this point all calls have been resolved
// Now when accessing someResult| anotherResult,
// you will have a value instead of a promise
JSbin示例：http://jsbin.com/xerifanima/edit?js安慰
注意：只要第一个等待调用发生在所有异步调用之后，那么等待调用是在同一条线上还是在不同的线上并不重要。见JohnnyHK的评论。
更新：根据@bergi的回答，这个答案在错误处理中的时间不同，它不会在错误发生时抛出错误，而是在所有承诺都执行后抛出错误。我将结果与@jonny的提示进行比较：[result1，result2]=Promise.all（[async1（），async2（）]），检查以下代码片段
常量correctAsync500ms=（）=>{return new Promise（解析=>{setTimeout（resolve，500，'correct500msResult'）；});};常量correctAsync100ms=（）=>{return new Promise（解析=>{setTimeout（resolve，100，'correct100msResult'）；});};常量拒绝同步100ms=（）=>{return new Promise（（resolve，reject）=>{setTimeout（拒绝，100，'拒绝100毫秒错误'）；});};const asyncInArray=异步（fun1，fun2）=>{const label='测试数组中的异步函数'；尝试{console.time（标签）；常量p1=fun1（）；常量p2=fun2（）；const result=[await p1，wait p2]；console.timeEnd（标签）；}捕获（e）{console.error（'错误为'，e）；console.timeEnd（标签）；}};常量asyncInPromiseAll=async（fun1，fun2）=>{const label='使用Promise.all测试异步函数'；尝试{console.time（标签）；let[value1，value2]=等待Promise。all（[fun1（），fun2（）]）；console.timeEnd（标签）；}捕获（e）{console.error（'错误为'，e）；console.timeEnd（标签）；}};（异步（）=>{console.group（'无错误的同步功能'）；console.log（'无错误的同步函数：启动'）等待异步InArray（correctAsync500ms，correctAsync 100ms）；等待异步InPromiseAll（correctAsync500ms，correctAsync 100ms）；console.groupEnd（）；console.group（'带错误的同步功能'）；console.log（'带有错误的同步函数：start'）等待异步InArray（correctAsync500ms，rejectAsync100ms）；等待异步InPromiseAll（correctAsync500ms，rejectAsync100ms）；console.groupEnd（）；})();
这可以通过Promise.allSettled（）实现，它类似于Promise.all（），但没有快速失败行为。
async function Promise1() {
throw "Failure!";
}
async function Promise2() {
return "Success!";
}
const [Promise1Result, Promise2Result] = await Promise.allSettled([Promise1(), Promise2()]);
console.log(Promise1Result); // {status: "rejected", reason: "Failure!"}
console.log(Promise2Result); // {status: "fulfilled", value: "Success!"}
注意：这是一个边缘功能，浏览器支持有限，因此我强烈建议为该功能添加polyfill。
