手写 Promise.all 的核心是用计数器跟踪完成数量并实现失败熔断:预先初始化结果数组按索引写入以保序,用 isRejected 标志确保首次 reject 即终止,同时处理空数组、非 Promise 值和同步异常。

手写 Promise.all 的核心在于:**用计数器跟踪已完成的 Promise 数量,同时支持任意一个失败就立即 reject(熔断)**。它不是简单地等全部 resolve,而是兼顾“并发执行”、“结果顺序保持”和“失败快退”三个关键行为。
计数器如何保证结果顺序与完成判定
Promise.all 返回的结果数组必须和输入数组顺序一致,哪怕第 0 个 Promise 最晚完成。因此不能靠 push,而要预先初始化结果数组,并用索引写入:
- 创建
results = new Array(promises.length),避免动态扩容影响顺序 - 每个 Promise resolve 后,用其原始索引(如
i)写入results[i] = value - 用计数器
resolvedCount累加成功数量;当resolvedCount === promises.length,说明全部完成,触发resolve(results)
如何实现“任一失败即熔断”
熔断不是靠 try/catch 包裹整个循环,而是为每个 Promise 单独监听 reject,并只允许第一次 reject 生效:
当用户要求为 Java 代码添加注释、修改注释、审查注释、整理注释格式,或要求按照代码注释规范处理 Java 文件时,使用本技能。本技能用于统一生成和维护 Java 类注释模板、按 Git 对比 release 判断版本号、补充每行代码上方中文块注释、调整注释空行规则,并保持 Java 文件 UTF-8 无 BOM 编码。典型触发场景包括:补充类注释、更新 @version、检查 @author 来源、整理行尾注释、把注释放到代码上一行、检查注释是否符合规范、构建前检查 Java 注释风格。
- 声明一个
isRejected = false标志位 - 每个 Promise 的
.catch()回调中,先判断if (isRejected) return - 首次失败时设
isRejected = true,并调用reject(error) - 注意:已 resolve 的 Promise 不会再触发 catch,所以不会干扰正常流程
边界情况必须处理
原生 Promise.all 对空数组、非 Promise 值、同步 throw 等都有明确定义,手写时需覆盖:
立即学习“Java免费学习笔记(深入)”;
-
空数组:直接 resolve
[](无需计数器,同步返回) -
非 Promise 值:用
Promise.resolve(item)统一包装,确保 .then/.catch 可用 -
同步 throw:例如
Promise.all([() => { throw 'err' }()]),需在循环内 try/catch 包裹Promise.resolve(item)调用
完整精简实现(含注释)
function PromiseAll(promises) {
return new Promise((resolve, reject) => {
if (!Array.isArray(promises)) {
return reject(new TypeError('Argument must be an array'));
}
const len = promises.length;
if (len === 0) return resolve([]);
let resolvedCount = 0;
let isRejected = false;
const results = new Array(len);
for (let i = 0; i < len; i++) {
// 统一转为 Promise,捕获同步错误
Promise.resolve(promises[i])
.then(value => {
if (isRejected) return;
results[i] = value;
resolvedCount++;
if (resolvedCount === len) resolve(results);
})
.catch(err => {
if (isRejected) return;
isRejected = true;
reject(err);
});
}
});
}

















