使用Promise.all实现限制并发请求函数 |
您所在的位置：网站首页 › 前端并发请求个数控制 › 使用Promise.all实现限制并发请求函数 |
|
文章目录
Promise.all 的简单解释：需求解释设计思路代码实现
Promise.all 的简单解释：
// 当以下数组中promise1, promise2, promise3都resolve之后，触发promise.all的then函数。
Promise.all([promise1, promise2, promise3]).then((values) => {
console.log(values);
});
需求解释
所谓并发请求，即有待请求接口100个，限制每次只能发出10个。即同一时刻最多有10个正在发送的请求。 每当10个之中有一个请求完成，则从待请求的接口中再取出一个发出。保证当前并发度仍旧为10。 直至最终请求完成。 设计思路简单思路如下：（假设并发请求函数名字为limitedRequest） 设定一个数组（命名为：pool），用于后续Promise.all的使用当limitedRequest被调用的时候，首先一次性发出10个请求，并放入到pool中每一个请求完成后的回调函数中继续触发下一个请求，而下一个请求返回Promise，他的回调函数继续绑定同样的回调函数，即循环调用。（看不懂就直接看代码更易懂）直到全部请求完成，停止。 代码实现具体代码如下 // 模仿一个fetch的异步函数，返回promise function mockFetch(param) { return new Promise((resovle) => { setTimeout(() => { resovle(param); }, 2000); }); } function limitedRequest(urls, maxNum) { const pool = []; // 处理maxNum比urls.length 还要大的情况。 const initSize = Math.min(urls.length, maxNum); for (let i = 0; i console.log('当前并发度：', pool.length); if (urls.length === 0) { console.log('并发请求已经全部发起'); return Promise.resolve(); } return run(urls.splice(0, 1)); } // 调用一次请求 function run(url) { return mockFetch(url).then(r); } // 全部请求完成的回调 Promise.all(pool).then(() => { console.log('请求已经全部结束'); }); } // 函数调用 limitedRequest([1, 2, 3, 4, 5, 6, 7, 8], 3); # 最终返回结果 $ node .\src\views\doc\detail\index.js 当前并发度： 3 当前并发度： 3 当前并发度： 3 当前并发度： 3 当前并发度： 3 当前并发度： 3 并发请求已经全部发起 当前并发度： 3 并发请求已经全部发起 当前并发度： 3 并发请求已经全部发起 请求已经全部结束 |
| CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3 |