JavaScript Promise 怎么实现异步操作的并发排序-js教程-PHP中文网

使用 promise.all() 结合索引映射可以实现异步操作的并发排序。具体做法是将原始数组的索引与数据一起打包，并行发起所有请求，待全部完成后，再根据原始索引对结果进行还原排序。

JavaScript Promise 怎么实现异步操作的并发排序

`Promise.all()` 如何保持原始顺序

Promise.all() 返回的结果数组顺序严格对应输入 Promise 数组的顺序。因此，只要我们在调用时按原始顺序传入 Promise，结果就会自动按原始顺序排列，无需额外排序逻辑。

JavaScript 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 的结果。这种机制天然支持基于原始索引的排序需求。

如何处理异步操作中的错误中断

当某个异步任务失败时，Promise.all() 会立即拒绝整个 Promise 链，导致其他已完成的任务结果丢失。若需容忍部分失败并继续处理成功项，应改用 Promise.allSettled() 并在后续步骤中过滤或排序有效结果。

Java Development Man

Java开发手册规约集合，基于阿里巴巴Java开发手册（嵩山版）。涵盖7大维度：编程规约、异常日志、单元测试、安全规约、MySQL数据库、工程结构、设计规约。

下载

JavaScript Promise 怎么实现异步操作的并发排序

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  runTask());
  await Promise.all(workers);
  return results;
};

// 测试：最多同时运行 2 个异步请求
chunkedAll([3, 1, 2], 2).then(res => console.log(res)); // [30, 10, 20]

该实现利用共享索引变量控制任务分配，确保每个输入项仅被处理一次，且结果数组按原始顺序填充。这种方式适用于需要严格控制资源消耗的批量异步场景。