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并发限制的主要内容,如果未能解决你的问题,请参考以下文章