触发了明显多余的“unhandledRejection”事件

Question

我们在我们的节点应用程序中为"unhandledRejection" 添加了一个事件处理程序，这个处理程序终止了进程（正如节点所说的将是默认的很快）。

但是，我们看到的事件似乎是多余的（或至少为时过早的）。

我们正在使用Q.allSettled（它处理被拒绝的承诺），我在调试器中看到承诺数组有两个元素，第一个 rejected 和第二个 pending（它将被解决）。在unhandledRejection 处理程序和allSettled 之后的then 中放置断点后，我首先得到unhandledRejection，然后立即得到then（因此拒绝 处理）。

unhandledRejection 的文档说（强调我的）：

'unhandledRejection' 事件在 Promise 被拒绝并且没有错误处理程序附加到 Promise 时发出在事件循环的一个轮次中。

我的假设是创建 promise 数组的机制在第一个 promise 被拒绝和数组创建之间阻塞，但我无法在玩具示例中重现这一点。

我能想出的最好的最小示例有点做作，但我认为它与我们的代码具有相同的根本原因。我在这里错过了什么吗？如果可以的话，node如何让unhandledRejection默认终止进程？

process.on("unhandledRejection", (reason, p) => {
    console.error(`### Got unhandled rejection: '${reason}'`);
});


function doesNotFireUnhandledRejection() {
    let rejected = Promise.reject('an error');
    return new Promise((resolve, reject) => {
        resolve(rejected);
    })
    .catch(err => console.log("Caught:", err));
}


function firesUnhandledRejection() {
    let rejected = Promise.reject('an error');
    return new Promise((resolve, reject) => {
        setTimeout(() => resolve(rejected), 0);
    })
    .catch(err => console.log("Caught:", err));
}

顺便说一句，setImmediate 会发生相同的行为，但 process.nextTick 不会发生相同的行为（尽管我可以发誓上周 process.nextTick 确实导致事件触发...）。

Answer 1

这是如何在未处理的拒绝时终止进程（预计在未来版本中将成为默认节点行为）：

process.on('unhandledRejection', err => {
  console.error(err);
  process.exit(1);
});

被拒绝的承诺应该与catch(...) 或then(..., ...) 链接在同一个tick 上，否则它被认为是未处理的拒绝。

在保证稍后处理拒绝的极少数情况下，可以将 promise 与 dummy catch 链接，以抑制对未处理拒绝的检测：

function firesUnhandledRejection() {
    const rejectedPromise = Promise.reject('an error');
    rejectedPromise.catch(() => {});

    return new Promise((resolve) => {
        setTimeout(() => resolve(rejectedPromise), 0);
    })
    .catch(err => console.log("Caught:", err));
}

Answer 2

回答你的问题：

• 具有微任务语义的事情（process.nextTick、then 处理程序、异步函数的延续和 enqueueMicrotask）发生在未处理的拒绝检查之前。
• 具有宏任务语义（定时器、i/o）的事情发生在未经处理的拒绝检查之后。

这就是我们所说的：“在事件循环的一个回合内”。

在这种情况下，Node.js 的行为符合预期。请注意，在您的情况下：

function firesUnhandledRejection() {
    let rejected = Promise.reject('an error'); // < -- this is the unhandled rejection
    return new Promise((resolve, reject) => { // <- this promise is totally fine
        setTimeout(() => resolve(rejected), 0); // <- you associate them too late
    })
    .catch(err => console.log("Caught:", err));
}

所以问题是太长时间（定时器触发）有一个没有错误处理程序的被拒绝的承诺。