[JavaScript知识库]Promise.all并发限制

前言：通过之前的介绍和学习，我们清楚了Promse.all在处理多个异步处理时非常有用。虽然非常好用，但Promse.all也存在一定的限制。那现在就来学习一下Promise.all并发限制。

情景还原

比如说我们要加载100个接口的数据，当这个100个接口的数据加载完成之后我们再返回一个加载完成。

思路一

如果我们按照Promise.all的思路去写的话，我们会这么写：

let urls = [
  'https://.../url1',
   ……
'https://.../url100'
];
function loadData(url) {
return new Promise((resolve, reject) => {
      $.get(url, result => {
        resolve(result)
      })
  })
};
let allList = []
urls.forEach(url => allList.push(loadData(url)))
Promise.all(allList).then(() => {
console.log('success')
})

我们思考一下，如果我们一次给后台同时发送1000个请求，那么后台会不会崩溃呢？

思路二

对于这样的问题我们需要怎么去解决呢，这个时候我们会想根据Promise.all的原理，将Promise.all的结果改装成串行执行的,如下：

Promise.asyncAll = function (promise) {
return new Promise((resolve, reject) => {
let index = 0
let result = []
if (promise.length === 0) {
          resolve(result)
      } else {
function runPromise () {
if (index === promise.length) {
            resolve(result);
          } else {
Promise.resolve(promise[index]).then(data => {
              result[index] = data;
              ++index;
              runPromise()
            }, err => {
              reject(err)
            });
          }
        }
        runPromise()
      }
  })
}

这样就不容易出现高并发的问题，但是新的问题又来了，我们这样操作的话，其实我们的执行效率非常的低。

假如说我们每个请求是1s这样的100个请求的话所用的时间就是100s，我们要等很久。

思路三

那么面对这个问题我们怎么去处理呢，其实我们可以考虑一下，一次并行请求多个，这样的话，对服务器的压力相对来说会减少一些，而且等待请求完成的时间也会相对应的减少一些。这个时候我们就依赖于我们上面的Promise.all的方法来进行实现：

Promise.asyncStep = function (promises) {
return new Promise((resolve, reject) => {
let index = 0
let stepCount = 10 // 并行多个
let result = []
let count = promise.length
if (promise.length === 0) {
        resolve(result)
    } else {
function runPromise () {
if (index === promise.length) {
          resolve(result);
        } else {
          stepCount = Math.min(count, stepCount)
for (let i = 0; i < stepCount; i++) {
            --count;
Promise.resolve(promise[index]).then(data => {
              result[index] = data;
              ++index;
            }, err => {
              reject(err)
            });
          }
          runPromise();
        }
      }
      runPromise()
    }
  })
}

这样基本就很好的解决了Promse.all一些并行所带来的限制，你学会了吗？