主页 / 问题 / 1388900
Accepted
Артём Ионаш
Asked:2022-08-10 16:28:54 +0800 CST2022-08-10 16:28:54 +0800 CST

如何用队列实现 Promise.all() 的类似物？

  • 772

如何Promise.all()用一个固定容量的动态队列来实现
，即在一个时间点，例如，最多处理 10 个并行请求？

const promises = Array(10)
  .fill(null)
  .map((item, i) => new Promise((resolve) => resolve(i)))

const arr = await PromiseAllByChanck.all(promises , 2)

换句话说，这样查询是由查询数组段逐块执行的？

javascript

1 个回答

  1. Best Answer

    事实是，创建的每个Promise实际上都是发送执行的请求，因此，在所需的解决方案中，不能存在“promise”数组这样的实体promises。

    也就是说，它们都是从这一行创建并“发送执行”的：

    const promises = Array(10)
  .fill(null)
  .map((item, i) => new Promise((resolve) => resolve(i)))
const five = await promises[5] // 5

    为了防止这种情况，您可以“转义”它们，或者更确切地说，将它们转换为异步函数：

    const tasks = Array(10)
  .fill(null)
  .map((item, i) => async () => i)
const five = await tasks[5]() // 5

    然后带有内部队列的模拟Promise.all()将如下所示：

    class ExecutorPool {
  constructor(size) {
    if (size < 1)
      throw new Error('[ExecutorPool] Размер очереди меньше единицы.')
    this._size = size
  }

  async execute(tasks) {
    const results = Array(tasks.length)
    const executors = Array(this._size)
      .fill(null)
      .map((e, executorId) => async (taskPool) => {
        while (true) {
          const task = taskPool.pop()
          if (!task) break

          const index = taskPool.length
          results[index] = await task()
          console.log(JSON.stringify({ taskId: results[index], executorId }))
        }
      })
    const taskPool = [...tasks]
    await Promise.all(executors.map((executor) => executor(taskPool)))
    return results
  }
}

new Promise(async () => {
  const tasks = Array(10)
    .fill(null)
    .map((item, i) => async () => i)
  const ePool = new ExecutorPool(2)
  const results = await ePool.execute(tasks)
  console.log(JSON.stringify(results))
})

    • 0

相关问题