Promise错误处理：await触发未预期的未捕获Promise拒绝问题

我想要并行调度多个文件系统相关任务，把它们存成Promise后先让任务执行一段时间，之后再进行await操作。但遇到了问题：当我await另一个无关的Promise时，某个文件系统Promise的错误会突然抛出。

以下是复现示例，未捕获错误会在await sleep(1000)行触发：

function sleep(ms) { return new Promise(resolve => setTimeout(resolve, ms)) }

async function work() {
    const p1 = new Promise((resolve, reject) => reject("p1 reject"))
    const p2 = new Promise((resolve, reject) => resolve("p2 resolve"))

    console.log("Sleeping")
    await sleep(1000)

    console.log("Awaiting p2")
    console.log("result", await p2)

    console.log("Awaiting p1")
    try {
        console.log("result", await p1)
    } catch (error) {
        console.log("caught:", error)
    }
}

work()

运行结果：

PS C:\test> node --version
v16.17.0
PS C:\test> node .\promise-error-handling.js
Sleeping
node:internal/process/promises:279
            triggerUncaughtException(err, true /* fromPromise */);
            ^

[UnhandledPromiseRejection: This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). The promise rejected with the reason "p1 reject".] {
  code: 'ERR_UNHANDLED_REJECTION'
}
PS C:\test> 

即使改用Promise.all也会出现同样问题：

function sleep(ms) { return new Promise(resolve => setTimeout(resolve, ms)) }

async function work() {
    const p1 = new Promise((resolve, reject) => reject("p1 reject"))
    const p2 = new Promise((resolve, reject) => resolve("p2 resolve"))

    try {
        console.log("Sleeping")
        await sleep(1000)
    } catch (error) {
        console.log("caught sleep", error)
    }

    try {
        await Promise.all([p1, p2])
    } catch (error) {
        console.log("caught:", error)
    }
}

work()

运行结果：

Sleeping
node:internal/process/promises:279
            triggerUncaughtException(err, true /* fromPromise */);
            ^

[UnhandledPromiseRejection: This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). The promise rejected with the reason "p1 reject".] {
  code: 'ERR_UNHANDLED_REJECTION'
}

问题根源 #

Promise在创建后会立即执行，一旦它被reject，Node.js的事件循环会在当前轮次结束后检查这个Promise是否有对应的错误处理（.catch()或try/await）。如果此时还没有绑定任何错误处理，Node.js就会判定为未处理的Promise拒绝，直接抛出错误——哪怕你之后打算处理这个错误，也已经来不及了。

在你的代码里，p1创建后立刻就reject了，但此时你还在await sleep(1000)，没有任何代码处理p1的错误，所以Node.js会在sleep的等待过程中抛出未处理错误。

解决方法 #

方法1：给Promise提前绑定错误处理 #

在创建Promise的同时，就给它绑定.catch()，让错误有一个兜底的处理，避免Node.js判定为未处理拒绝。之后你还可以正常await这个Promise并处理结果。

示例修正第一个代码：

function sleep(ms) { return new Promise(resolve => setTimeout(resolve, ms)) }

async function work() {
    // 给p1提前绑定catch，将错误包装后返回
    const p1 = new Promise((resolve, reject) => reject("p1 reject")).catch(err => ({ error: err }));
    const p2 = new Promise((resolve, reject) => resolve("p2 resolve"))

    console.log("Sleeping")
    await sleep(1000)

    console.log("Awaiting p2")
    console.log("result", await p2)

    console.log("Awaiting p1")
    const result1 = await p1;
    if (result1.error) {
        console.log("caught:", result1.error)
    } else {
        console.log("result", result1)
    }
}

work()

方法2：用包装函数统一处理任务 #

如果有多个并行任务，可以写一个包装函数，自动给每个任务的Promise绑定错误处理，避免重复代码：

// 包装函数：执行任务并捕获错误，返回包含结果或错误的对象
function wrapParallelTask(taskFn) {
    return taskFn().catch(err => ({ error: err }));
}

function sleep(ms) { return new Promise(resolve => setTimeout(resolve, ms)) }

async function work() {
    // 用包装函数启动并行任务
    const p1 = wrapParallelTask(() => new Promise((resolve, reject) => reject("p1 reject")));
    const p2 = wrapParallelTask(() => new Promise((resolve, reject) => resolve("p2 resolve")));

    console.log("Sleeping")
    await sleep(1000)

    // 统一处理所有任务结果
    const [result1, result2] = await Promise.all([p1, p2]);
    
    if (result1.error) {
        console.log("p1 caught:", result1.error);
    } else {
        console.log("p1 result:", result1);
    }
    
    if (result2.error) {
        console.log("p2 caught:", result2.error);
    } else {
        console.log("p2 result:", result2);
    }
}

work()

方法3：全局监听未处理拒绝（不推荐） #

可以全局监听unhandledRejection事件来兜底，但这种方法会掩盖真正的未处理错误，不建议作为常规方案：

process.on('unhandledRejection', (err) => {
    // 这里可以做日志记录等兜底操作
    console.log("全局捕获未处理拒绝:", err);
});

总结 #

核心原则是：不要让rejected状态的Promise在没有错误处理的情况下存在。只要在Promise创建后尽快绑定错误处理（不管是.catch()还是通过包装函数），就能避免Node.js抛出未处理拒绝错误，同时不影响你之后await处理任务结果。

内容的提问来源于stack exchange，提问作者nneil