第一个区别 - 快速失败
我同意@zzzzBov 的回答,但“快速失败”的优势Promise.all
并不是唯一的区别。评论中的一些用户询问为什么使用Promise.all
它是值得的,因为它只会在负面情况下更快(当某些任务失败时)。我问,为什么不呢?如果我有两个独立的异步并行任务,第一个需要很长时间才能解决,但第二个在很短的时间内被拒绝,为什么让用户等待更长的调用完成以接收错误消息?在实际应用中,我们必须考虑负面情况。但是好的 - 在这第一个区别中,您可以决定使用哪种替代方案:Promise.all
vs. multiple await
。
第二个区别 - 错误处理
但是在考虑错误处理时,您必须使用Promise.all
. 无法正确处理由多个await
s触发的异步并行任务的错误。在消极的情况下,无论您在何处使用 try/catch,您将始终以UnhandledPromiseRejectionWarning
and结尾PromiseRejectionHandledWarning
。这就是为什么Promise.all
被设计。当然有人会说我们可以使用process.on('unhandledRejection', err => {})
and来抑制这些错误,process.on('rejectionHandled', err => {})
但这不是一个好习惯。我在 Internet 上发现了许多示例,它们根本不考虑对两个或多个独立异步并行任务进行错误处理,或者以错误的方式考虑它——只是使用 try/catch 并希望它会捕获错误。在这方面几乎不可能找到好的做法。
概括
TL;DR:永远不要将多个await
用于两个或多个独立的异步并行任务,因为您将无法正确处理错误。始终Promise.all()
用于此用例。
Async/await
不是 Promises 的替代品,它只是使用 Promises 的一种很好的方式。异步代码以“同步风格”编写,我们可以避免then
在 Promise 中出现多个s。
有人说在使用时Promise.all()
我们不能单独处理任务错误,我们只能处理来自第一个被拒绝的Promise的错误(单独处理对于记录很有用)。这不是问题 - 请参阅此答案底部的“添加”标题。
例子
考虑这个异步任务......
const task = function(taskNum, seconds, negativeScenario) {
return new Promise((resolve, reject) => {
setTimeout(_ => {
if (negativeScenario)
reject(new Error('Task ' + taskNum + ' failed!'));
else
resolve('Task ' + taskNum + ' succeed!');
}, seconds * 1000)
});
};
当您在积极的场景中运行任务时Promise.all
,多个await
s之间没有区别。两个示例都Task 1 succeed! Task 2 succeed!
在 5 秒后结束。
// Promise.all alternative
const run = async function() {
// tasks run immediate in parallel and wait for both results
let [r1, r2] = await Promise.all([
task(1, 5, false),
task(2, 5, false)
]);
console.log(r1 + ' ' + r2);
};
run();
// at 5th sec: Task 1 succeed! Task 2 succeed!
// multiple await alternative
const run = async function() {
// tasks run immediate in parallel
let t1 = task(1, 5, false);
let t2 = task(2, 5, false);
// wait for both results
let r1 = await t1;
let r2 = await t2;
console.log(r1 + ' ' + r2);
};
run();
// at 5th sec: Task 1 succeed! Task 2 succeed!
但是,当第一个任务耗时10秒成功,第二个任务耗时5秒失败时,发出的错误是有区别的。
// Promise.all alternative
const run = async function() {
let [r1, r2] = await Promise.all([
task(1, 10, false),
task(2, 5, true)
]);
console.log(r1 + ' ' + r2);
};
run();
// at 5th sec: UnhandledPromiseRejectionWarning: Error: Task 2 failed!
// multiple await alternative
const run = async function() {
let t1 = task(1, 10, false);
let t2 = task(2, 5, true);
let r1 = await t1;
let r2 = await t2;
console.log(r1 + ' ' + r2);
};
run();
// at 5th sec: UnhandledPromiseRejectionWarning: Error: Task 2 failed!
// at 10th sec: PromiseRejectionHandledWarning: Promise rejection was handled asynchronously (rejection id: 1)
// at 10th sec: UnhandledPromiseRejectionWarning: Error: Task 2 failed!
我们应该已经注意到,await
在并行使用多个s时我们做错了。让我们尝试处理错误:
// Promise.all alternative
const run = async function() {
let [r1, r2] = await Promise.all([
task(1, 10, false),
task(2, 5, true)
]);
console.log(r1 + ' ' + r2);
};
run().catch(err => { console.log('Caught error', err); });
// at 5th sec: Caught error Error: Task 2 failed!
如您所见,为了成功处理错误,我们只需要在run
函数中添加一个 catch并将带有 catch 逻辑的代码添加到回调中。我们不需要处理run
函数内部的错误,因为异步函数会自动执行此操作——Promise拒绝task
函数会导致拒绝run
函数。
为了避免回调,我们可以使用“同步样式”(async/ await
+ try/catch),
try { await run(); } catch(err) { }
但在本例中这是不可能的,因为我们不能await
在主线程中使用 - 它只能在异步函数中使用(因为没有人想要阻塞主线程)。要测试处理是否以“同步样式”工作,我们可以run
从另一个异步函数调用该函数或使用 IIFE(立即调用函数表达式:MDN):
(async function() {
try {
await run();
} catch(err) {
console.log('Caught error', err);
}
})();
这是运行两个或多个异步并行任务和处理错误的唯一正确方法。你应该避免下面的例子。
不好的例子
// multiple await alternative
const run = async function() {
let t1 = task(1, 10, false);
let t2 = task(2, 5, true);
let r1 = await t1;
let r2 = await t2;
console.log(r1 + ' ' + r2);
};
我们可以尝试通过几种方式来处理上面代码中的错误......
try { run(); } catch(err) { console.log('Caught error', err); };
// at 5th sec: UnhandledPromiseRejectionWarning: Error: Task 2 failed!
// at 10th sec: UnhandledPromiseRejectionWarning: Error: Task 2 failed!
// at 10th sec: PromiseRejectionHandledWarning: Promise rejection was handled
...没有被捕获,因为它处理同步代码但是run
是异步的。
run().catch(err => { console.log('Caught error', err); });
// at 5th sec: UnhandledPromiseRejectionWarning: Error: Task 2 failed!
// at 10th sec: Caught error Error: Task 2 failed!
// at 10th sec: PromiseRejectionHandledWarning: Promise rejection was handled asynchronously (rejection id: 1)
……嗯?我们首先看到任务 2 的错误没有被处理,然后它被捕获。误导性并且在控制台中仍然充满错误,这种方式仍然无法使用。
(async function() { try { await run(); } catch(err) { console.log('Caught error', err); }; })();
// at 5th sec: UnhandledPromiseRejectionWarning: Error: Task 2 failed!
// at 10th sec: Caught error Error: Task 2 failed!
// at 10th sec: PromiseRejectionHandledWarning: Promise rejection was handled asynchronously (rejection id: 1)
……和上面一样。用户@Qwerty 在他删除的答案中询问了这种奇怪的行为,其中错误似乎被捕获但也未处理。我们捕获错误,因为run()
在await
关键字行上被拒绝,并且可以在调用时使用 try/catch 捕获run()
。我们还得到一个未处理的错误,因为我们正在同步调用一个异步任务函数(没有await
关键字),并且这个任务在run()
函数外运行并失败。
这类似于在调用某些调用 setTimeout 的同步函数时,我们无法通过 try/catch 处理错误:
function test() {
setTimeout(function() {
console.log(causesError);
}, 0);
};
try {
test();
} catch(e) {
/* this will never catch error */
}`.
另一个糟糕的例子:
const run = async function() {
try {
let t1 = task(1, 10, false);
let t2 = task(2, 5, true);
let r1 = await t1;
let r2 = await t2;
}
catch (err) {
return new Error(err);
}
console.log(r1 + ' ' + r2);
};
run().catch(err => { console.log('Caught error', err); });
// at 5th sec: UnhandledPromiseRejectionWarning: Error: Task 2 failed!
// at 10th sec: PromiseRejectionHandledWarning: Promise rejection was handled asynchronously (rejection id: 1)
...“仅”两个错误(第三个缺失)但没有发现任何错误。
添加(处理单独的任务错误和首次失败错误)
const run = async function() {
let [r1, r2] = await Promise.all([
task(1, 10, true).catch(err => { console.log('Task 1 failed!'); throw err; }),
task(2, 5, true).catch(err => { console.log('Task 2 failed!'); throw err; })
]);
console.log(r1 + ' ' + r2);
};
run().catch(err => { console.log('Run failed (does not matter which task)!'); });
// at 5th sec: Task 2 failed!
// at 5th sec: Run failed (does not matter which task)!
// at 10th sec: Task 1 failed!
...请注意,在此示例中,我拒绝了这两个任务以更好地演示会发生什么(throw err
用于触发最终错误)。