Promise.all并发限制

Posted 2022-11-20 前端e站

前言：通过之前的介绍和学习，我们清楚了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一些并行所带来的限制，你学会了吗？