Promise.all并发限制

Posted 前端e站

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了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一些并行所带来的限制,你学会了吗?

2022深度学习开发者峰会 5月20日13:00让我们相聚云端,共襄盛会!

以上是关于Promise.all并发限制的主要内容,如果未能解决你的问题,请参考以下文章

Promise.all并发限制

Promise.all并发限制

Promise.all 限制并发

Promise.all 限制并发

Promise.all 限制并发

使用 ES6 的 Promise.all() 时限制并发的最佳方法是啥?