
本文旨在解决在使用 Bluebird Promise 实现可取消的异步操作时,async/await 导致的程序卡死问题。我们将探讨如何利用 ES6 内置的 AbortController 来实现 Promise 的取消,并确保程序在取消后能够正常执行后续流程,避免代码阻塞。通过示例代码,我们将展示如何将 AbortController 集成到你的异步函数中,并正确处理取消事件,从而构建更加健壮和可控的异步代码。
在使用 Bluebird 的可取消 Promise 时,结合 async/await 可能会遇到一些问题,尤其是在 Promise 被取消的情况下,程序可能会卡在 await 语句处,导致后续代码无法执行。 这主要是因为取消操作没有正确地通知 await 表达式,使得它一直等待 Promise 的 resolve 或 reject。
解决这个问题的关键在于使用 ES6 内置的 AbortController。AbortController 提供了一种标准的方式来取消异步操作,并且可以与 Promise 结合使用。
使用 AbortController 取消 Promise
以下是一个使用 AbortController 实现可取消 Promise 的示例:
let myP = (signal) =>
new Promise((resolve, reject) => {
const tm = setTimeout(function () {
console.log("before resolve");
resolve("Success!"); // Yay! Everything went well!
}, 2500);
// signal.onabort = () => { // 旧写法,不推荐
signal.addEventListener('abort', () => {
console.log('aborted');
clearTimeout(tm);
reject(new Error('Promise Aborted')); // 建议 reject,方便错误处理
// resolve(); // 也可以 resolve,取决于业务需求
});
});
const run = async () => {
console.log("Start");
const controller = new AbortController();
const signal = controller.signal;
const prm = myP(signal);
setTimeout(() => controller.abort(), 1000);
try {
await prm;
console.log("After await prm");
} catch (e) {
console.error("Caught error:", e);
} finally {
console.log("Finished");
}
};
run();代码解释:
- AbortController 的创建: 首先,我们创建一个 AbortController 实例。
- signal 的传递: 将 AbortController 的 signal 传递给 myP 函数。signal 对象用于监听取消事件。
- addEventListener('abort', ...): 在 myP 函数内部,我们使用 signal.addEventListener('abort', ...) 监听 abort 事件。 当 AbortController 调用 abort() 方法时,该事件会被触发。
- 取消处理: 在 abort 事件处理函数中,我们执行取消操作,包括清除定时器 clearTimeout(tm),并调用 reject(new Error('Promise Aborted')) 来拒绝 Promise。 也可以根据业务需求选择 resolve()。 建议使用 reject,因为这样可以在 catch 块中处理取消错误。
- controller.abort() 的调用: 在 run 函数中,我们使用 setTimeout 在 1 秒后调用 controller.abort(),模拟取消操作。
- 错误处理: 使用 try...catch 块来捕获可能发生的错误,包括取消导致的错误。
注意事项:
- reject vs resolve: 当 Promise 被取消时,应该选择 reject 还是 resolve 取决于你的业务逻辑。 如果取消被视为一种错误情况,则应该 reject Promise。 如果取消只是中断了操作,并且不需要进一步处理,则可以 resolve Promise。
- 资源清理: 在 abort 事件处理函数中,务必清理所有已分配的资源,例如定时器、网络连接等,以避免内存泄漏。
- signal.onabort vs signal.addEventListener('abort', ...): 建议使用 addEventListener,因为它允许你注册多个取消处理函数。 避免使用 signal.onabort = ...,因为它只能注册一个处理函数。
- 多个 Promise 的取消: 可以使用同一个 AbortController 的 signal 来取消多个 Promise。 这在需要同时取消多个相关操作时非常有用。
总结
AbortController 提供了一种简洁而强大的方式来取消异步操作,并且可以与 async/await 和 Promise 无缝集成。 通过使用 AbortController,你可以构建更加健壮和可控的异步代码,避免程序卡死,并有效地管理资源。 记得在取消处理函数中清理资源并根据业务需求选择 reject 或 resolve Promise。










