使用 promise.all() 结合索引映射可以实现异步操作的并发排序。具体做法是将原始数组的索引与数据一起打包，并行发起所有请求，待全部完成后，再根据原始索引对结果进行还原排序。
Promise.all() 如何保持原始顺序
Promise.all() 返回的结果数组顺序严格对应输入 Promise 数组的顺序。因此，只要我们在调用时按原始顺序传入 Promise，结果就会自动按原始顺序排列，无需额外排序逻辑。
const items = [3, 1, 2];
// 模拟异步操作，耗时与值成正比
const fetchWithDelay = (val) => new Promise(resolve => {
setTimeout(() => resolve(val * 10), val * 100);
});
// 1. 创建 Promise 数组（保持原始顺序）
const promises = items.map(item => fetchWithDelay(item));
// 2. 并发执行并等待完成
Promise.all(promises).then(results => {
console.log(results); // [30, 10, 20]
// 结果顺序与 items 一致：[3, 1, 2] -> [30, 10, 20]
});
上述代码中，虽然 fetchWithDelay(3) 耗时最长，但 Promise.all() 确保输出数组的第一个元素始终对应输入数组的第一个 Promise 的结果。这种机制天然支持基于原始索引的排序需求。
立即学习“Java免费学习笔记（深入）”；
Java开发手册规约集合，基于阿里巴巴Java开发手册（嵩山版）。 涵盖7大维度：编程规约、异常日志、单元测试、安全规约、MySQL数据库、工程结构、设计规约。
如何处理异步操作中的错误中断
当某个异步任务失败时，Promise.all() 会立即拒绝整个 Promise 链，导致其他已完成的任务结果丢失。若需容忍部分失败并继续处理成功项，应改用 Promise.allSettled() 并在后续步骤中过滤或排序有效结果。
const items = [3, 1, 2];
const fetchWithRandomFail = (val) => new Promise((resolve, reject) => {
// 假设值为 1 时随机失败
if (val === 1 && Math.random() > 0.5) {
reject(new Error('Failed for ' + val));
} else {
setTimeout(() => resolve({ id: val, data: val * 10 }), 100);
}
});
// 使用 allSettled 避免单点故障
Promise.allSettled(items.map(item => fetchWithRandomFail(item)))
.then(results => {
// 过滤出成功的结果
const successResults = results
.filter(r => r.status === 'fulfilled')
.map(r => r.value);
// 此时 successResults 仍保持原始相对顺序
console.log(successResults);
// 例如: [{id: 3, data: 30}, {id: 2, data: 20}] （若 1 失败）
});
通过 allSettled()，即使中间任务失败，我们仍能获取所有任务的最终状态。在业务逻辑中，可进一步根据原始索引对成功结果进行重排，确保下游系统接收到的数据顺序符合预期。
基于输入数组长度和并发数限制的具体问题
当输入数组较大时，无限制并发可能导致服务器过载或内存溢出。可通过分片（chunking）方式控制并发数量，例如每次只处理 N 个 Promise，待前一批完成后再生成下一批，从而平衡速度与稳定性。
const chunkedAll = async (items, concurrency) => {
const results = new Array(items.length);
let index = 0;
const runTask = async () => {
while (index < items.length) {
const currentIndex = index++;
results[currentIndex] = await fetchWithDelay(items[currentIndex]);
}
};
// 启动指定数量的并发任务
const workers = Array.from({ length: concurrency }, () => runTask());
await Promise.all(workers);
return results;
};
// 测试：最多同时运行 2 个异步请求
chunkedAll([3, 1, 2], 2).then(res => console.log(res)); // [30, 10, 20]
该实现利用共享索引变量控制任务分配，确保每个输入项仅被处理一次，且结果数组按原始顺序填充。这种方式适用于需要严格控制资源消耗的批量异步场景。
