js Promise并发控制数量的方法

JS Promise并发控制数量的方法指的是在使用 Promise 进行并发操作时，控制并发数量的技巧。

一般而言，我们可以使用 Promise.all() 或 Promise.race() 来处理并发请求，并获取返回结果。但是，有时我们需要控制并发请求的数量，避免发送过多的请求导致服务端出错或无响应。

以下是 JS Promise 并发控制数量的方法：

1. 使用 async/await

通过 async/await 自动生成 Promise，且可以方便的控制并发数量。

示例：

const getData = async (param) => {
  // fetch data here
}

const processData = async (dataArr) => {
  const concurrency = 5 // 最大并发数量
  const data = []
  let executing = []

  // 初始化
  for (let i = 0; i < concurrency; i++) {
    executing.push(getData(dataArr.shift()))
  }

  while (executing.length) {
    try {
      const task = await Promise.race(executing) // 获取执行完毕的 Promise
      executing = executing.filter((e) => e !== task)
      data.push(await getData(dataArr.shift()))

      // 将新的 Promise 加入执行队列
      if (dataArr.length) {
        executing.push(getData(dataArr.shift()))
      }
    } catch (e) {
      console.error('ERROR: ', e)
    }
  }

  console.log(data)
}

const dataArr = [...]
processData(dataArr)

上述代码中，首先定义了一个 getData() 函数，用于处理从服务端获取的数据。然后，使用 processData() 函数来控制并发请求数量。其中，我们通过 while 循环处理所有数据，并维护一个执行队列，保证当前执行的 Promise 和最大并发数一样。

1. 使用第三方库

我们也可以使用 flow-control 库，它提供了一些实用的工具函数，用于处理 JS Promise 并发控制，如需要控制并发数量的情况下可以使用 Promise.map() 函数。

示例：

const flowControl = require('flow-control')

const getData = async (param) => {
  // fetch data here
}

const processData = async (dataArr) => {
  const concurrency = 5 // 最大并发数量

  const results = await flowControl.map(dataArr, concurrency, async (item) => {
    return getData(item)
  })

  console.log(results)
}

const dataArr = [...]
processData(dataArr)

上述代码中，我们使用了 flow-control 库中的 Promise.map() 函数，用于控制并发请求数量。该函数接收三个参数：数组、并发数和回调函数。在回调函数中，我们调用了 getData() 函数获取数据。调用结束后，我们可以通过 await 来获取所有的并发请求的返回结果。

总结：

在前端异步处理任务中，Promise 处理并发请求是一种通用的技巧。在需要控制并发数量的情况下，通过 async/await 或第三方库来实现是两种通用方法。