本文详解如何利用 `promise.all()` 实现 promise 的并发执行与**按创建顺序（fifo）的确定性结果返回**，避免手动实现队列逻辑，提升代码简洁性、可维护性与执行效率。
在实际开发中，常遇到一类典型需求：需同时发起多个异步任务（如 API 请求、数据库写入、延时处理等）以提升吞吐量，但又要求最终结果严格按任务提交的先后顺序被消费或处理（例如日志落库、UI 按序渲染、流式响应组装）。此时，若错误地使用 Promise.then() 链式串行执行，将严重牺牲性能；而若直接 await 每个 Promise，则仍为串行。
Promise.all() 正是解决该问题的标准、高效且语义清晰的方案：
- ✅ 并发执行：所有传入的 Promise 立即并行启动（无阻塞等待）；
- ✅ 顺序返回：结果数组严格按输入 Promise 的索引顺序排列，与完成时间无关；
- ✅ 简洁可靠：无需手写队列类、递归调度或状态管理，规避竞态与内存泄漏风险。
以下为优化后的完整示例（适配原场景中的 for await 流式数据源）：
function sleep(ms) {
return new Promise(resolve => setTimeout(resolve, ms));
}
function randomNumber(min, max) {
return Math.floor(Math.random() * (max - min + 1)) + min;
}
// 模拟异步数据源（如事件流、数据库游标）
async function* getSwaps() {
for (let i = 0; i < 5; i++) {
await sleep(100); // 模拟流式拉取延迟
yield { id: i, data: `swap-${i}` };
}
}
async function run() {
const promises = []; // 存储待并发执行的 Promise 实例
// 注意：此处使用 for await 保证流式消费，但立即构造并推入 Promise
let i = 0;
for await (const log of getSwaps()) {
const promise = (async () => {
await sleep(randomNumber(300, 1000)); // 模拟不等长异步操作
return { index: i, value: log.id, timestamp: Date.now() };
})();
promises.push(promise);
i++;
}
// 关键：Promise.all 并发执行全部 promise，并按顺序返回结果
try {
const results = await Promise.all(promises);
results.forEach((result, idx) => {
console.log(`[Order ${idx}]`, result); // 输出顺序恒为 0,1,2,3,4
// ✅ 此处可安全执行顺序敏感操作，如：写入数据库、更新有序列表等
});
} catch (error) {
console.error("At least one promise rejected:", error);
}
}
run();⚠️ 重要注意事项：Promise.all() 具有“全或无”特性：任一 Promise 拒绝（reject），整个 Promise.all() 立即拒绝，不会等待其余 Promise 完成。若需容错，请改用 Promise.allSettled()；结果顺序完全由 promises 数组的索引决定，与各 Promise 的实际完成时间无关——这正是满足“按提交顺序解析”的核心保障；原 PromiseQueue 类存在潜在风险：未处理 Promise 拒绝、无取消机制、#dequeue 递归调用在超长队列下可能引发栈溢出，且违背 Promise 的组合式编程范式。
总结：当目标是“并发执行 + 顺序消费”时，Promise.all() 是最符合直觉、最健壮且最易维护的原生方案。它将复杂的调度逻辑下沉至引擎层，开发者只需专注构建 Promise 数组并声明性地消费结果。务必优先选用此模式，而非自行实现队列调度器。
立即学习“Java免费学习笔记（深入）”；
