本文介绍使用 `promise.all()` 实现 promise 并行执行与顺序返回的高效方案，替代手动维护队列的复杂逻辑，兼顾性能与可读性。
在 JavaScript 异步编程中，一个常见需求是：同时启动多个异步任务（充分利用并发能力），但确保最终结果严格按任务创建/提交的顺序被处理。例如，在持续拉取链上交易日志（getSwaps()）的长时运行流程中，每个日志需异步处理（如休眠模拟 I/O、写入数据库），但数据库写入必须保持原始事件顺序，否则将导致数据错乱。
此时，自行实现类似 PromiseQueue 的串行调度器（如问题中基于递归 #dequeue 的类）虽可行，却存在明显缺陷：
- ❌ 违背并发初衷：所有 Promise 实际被强制串行等待，无法并行执行；
- ❌ 逻辑冗余：需手动管理队列、状态、回调链，易出错且难以调试；
- ❌ 资源浪费：长时间运行场景下，内存中堆积未 resolve 的 resolve 函数引用，存在潜在泄漏风险。
正确解法是——Promise.all()。它天然满足两大核心要求：
✅ 并行执行：所有传入的 Promise 立即启动（无阻塞等待）；
✅ 顺序返回：结果数组索引严格对应输入 Promise 的声明顺序（非完成顺序）。
以下为优化后的完整实现：
function sleep(ms) {
return new Promise(resolve => setTimeout(resolve, ms));
}
function randomNumber(min, max) {
return Math.floor(Math.random() * (max - min + 1)) + min;
}
// 模拟异步数据源（替换为实际的 for await...of 逻辑）
async function* getSwaps() {
for (let i = 0; i < 20; i++) {
yield { id: i };
}
}
async function run() {
const promises = []; // 存储所有待执行的 Promise 实例
// 【关键】立即创建并推入 Promise（并行启动）
for await (const log of getSwaps()) {
const i = log.id;
const promise = (async () => {
await sleep(randomNumber(300, 1000)); // 模拟异步处理
return i; // 返回结果（将按原始顺序出现在结果数组中）
})();
promises.push(promise);
}
// 【关键】Promise.all 并行等待，结果按 promises 数组索引顺序排列
try {
const results = await Promise.all(promises);
results.forEach((value, index) => {
console.log(`[Index ${index}] Result:`, value);
// ✅ 此处可安全执行顺序敏感操作，如写入数据库
// writeDataToDB(value);
});
} catch (error) {
console.error('At least one promise rejected:', error);
// 注意：Promise.all 遇任一拒绝即整体拒绝，如需容错请改用 Promise.allSettled
}
}
run();⚠️ 重要注意事项
- 闭包陷阱：示例中 for await 循环内直接使用 log.id 而非循环变量 i（避免经典 var 提升问题），若用普通 for (let i...) 则 let 已确保块级作用域，无需额外处理。
- 错误处理：Promise.all() 是“全或无”策略——任一 Promise 拒绝，整个调用即拒绝。若需独立处理每个 Promise 的成功/失败状态，请改用 Promise.allSettled()，它始终返回包含 {status, value/reason} 的结果数组。
- 内存与流控：对“可能运行数小时”的海量数据流（如问题所述），直接累积所有 Promise 到数组可能导致内存溢出。此时应结合分批处理（如每 100 个一组调用 Promise.all）或使用 for await + 限流队列（如 p-map 库），而非完全放弃并行。
✅ 总结
Promise.all() 是解决“并行执行、顺序消费”场景的标准、简洁、高性能方案。它消除了手工队列调度的复杂性，让代码更接近业务意图——专注定义任务，而非调度细节。在保证结果顺序性的前提下，最大化异步并发效率，是现代 JavaScript 异步编程的基石实践之一。
