如何实现 promise.map，限制 promise 并发数

要实现 `promise.map` 并限制 promise 的并发数，可以使用 `Promise.all` 结合 `Promise.race` 来实现。

首先，将要处理的数据数组分割成多个小数组，每个小数组的长度等于并发数。然后，使用 `Array.map` 方法对每个小数组创建一个 Promise，将 Promise 存放在一个新的数组中。

接下来，使用 `Promise.all` 来等待所有 Promise 完成，并返回一个新的 Promise。在这个新的 Promise 中，使用 `Promise.race` 来限制并发数，每次只执行指定数量的 Promise。当其中一个 Promise 完成时，会触发 `Promise.race` 返回的 Promise，然后继续执行下一个 Promise，以此类推。

下面是一个示例的实现代码：

function promiseMap(array, concurrency, mapper) {
  const chunks = [];
  for (let i = 0; i < array.length; i += concurrency) {
    chunks.push(array.slice(i, i + concurrency));
  }

  const promises = chunks.map(chunk => {
    return Promise.all(chunk.map(mapper));
  });

  return Promise.all(promises).then(results => {
    return [].concat(...results);
  });
}

使用示例：

const data = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10];

function asyncTask(item) {
  return new Promise(resolve => {
    setTimeout(() => {
      console.log(`Processing item: ${item}`);
      resolve(item * 2);
    }, 1000);
  });
}

promiseMap(data, 3, asyncTask).then(results => {
  console.log('All tasks completed:', results);
});

在上述示例中，`promiseMap` 函数将 `data` 数组中的每个元素传递给 `asyncTask` 函数进行处理，并限制了并发数为 3。输出结果会按照并发数限制的顺序进行处理，每个任务间隔 1 秒执行。

这样，你就可以实现一个带有并发限制的 `promise.map` 函数。