Promise.all 中的错误处理类似于异步/等待语法中的流

Question

我有一些问题需要以“并行”方式处理多个拒绝。 当我们“并行等待”时如何处理异步函数中的拒绝。
这里是一个例子：

function in_2_sec(number) {
    return new Promise((resolve, reject) => {
        setTimeout(() => {
            reject('Error ' + number);
        }, 2000);
    }) 
}

async function f1() {
    try {
        let a = in_2_sec(3);
        let b = in_2_sec(30);
        return await a + await b; // awaiting in "parallel"
    } catch(err) {
        console.log('Error', err);
        return false;
    }
}

async function f2() {
    try {
        let a = await Promise.all([in_2_sec(3), in_2_sec(30)]);
        return a[0] + a[1];
    } catch(err) {
        console.log('Error', err);
        return false;
    }
}

// f1().then(console.log) // UnhandledPromiseRejectionWarning
// f2().then(console.log) // Nice

f1() 在节点中创建UnhandledPromiseRejectionWarning，因为第二次拒绝（b）没有处理。
f2() 完美运行，Promise.all() 可以解决问题，但是如何使用仅 async/await 语法而不使用 Promise.all() 来制作 f2()？

Answer 1

f2() 完美运行，Promise.all() 可以解决问题，但是如何使用仅 async/await 语法而不使用 Promise.all() 来制作 f2()？

一点也不。 使用Promise.all！ 这就是它的用途。不要想到 async/await 替换承诺 - 你仍然在使用它们，它只是 then 调用的语法糖。 Promise.all 没有语法替换。

当然也可以自己重新实现Promise.all 的行为（依赖于Promise 构造函数和.then 原语），但你真的不想这样做（有太多陷阱)。

Answer 2

我能想到但我不喜欢的最简单的方法是在错误路径中对catch 进行无条件调用，可能使用实用程序函数。

使用这些实用功能：

function noop() {
}

function markHandled(...promises) {
    promises.forEach(p => p && p.catch(noop));
}

是：

async function f2() {
    let a, b;
    try {
        a = in_2_sec(3);
        b = in_2_sec(30);
        return await a + await b;
    } catch(err) {
        console.log('Error', err);
        markHandled(a, b);
        return false;
    }
}

这样，我们明确地忽略了我们不关心的拒绝，发现了主要错误。

例子：

function in_2_sec(number) {
    return new Promise((resolve, reject) => {
        setTimeout(() => {
            reject('Error ' + number);
        }, 2000);
    }) 
}

function noop() {
}

function markHandled(...promises) {
    promises.forEach(p => p && p.catch(noop));
}

async function f2() {
    let a, b;
    try {
        a = in_2_sec(3);
        b = in_2_sec(30);
        return await a + await b;
    } catch(err) {
        console.log('Error', err);
        markHandled(a, b);
        return false;
    }
}

f2().then(console.log);