需求

• 控制網絡請求并發數
• 控制并發按順序返回結果

---

碼

/**
* 控制并發
* @param {Function} fn 邏輯處理函數
* @param {Array} arr 發送的數據
* @param {Number} [max=3] 并發數 默認3
* @param {Number} [order=false] 按順序返回執行結果 默認false
* @param {Number} [retry=1] 重試次數 默認1
* @returns {Promise} 返回Promise
*/
const reqPool = (fn, arr, max = 3, order = false, retry = 1) => {let reqList        = [...arr],                                        //不改變arrresData        = order ? Array(reqList.length).fill(0, 0) : [],   //  order = true 填充返回的數據curRuningCount = 0,                                               //限制內的第n個并發 runedCount     = 0,                                               //已執行的數量                         runingIndex    = 0;                                               //當前執行下標                       return new Promise(res => {const run = _ => {while (curRuningCount < max && reqList.length) {curRuningCount++const chunk = reqList.shift();(i => {/*** 當前重試次數 */let _retry = 0const add = (i2, data) => fn(data).then(r => {runedCount++order ? resData[i2] = r : resData.push(r)}).catch(err => {_retry++const repMore = _retry > retryif (!repMore) {add(i2, data)console.log(data, '重試' + _retry + '次');} else {order ? resData[i2] = err : resData.push(err)runedCount++}}).finally(_ => {curRuningCount--if (runedCount === arr.length) res(resData)run()});add(i, chunk)})(runingIndex++)}}run()})
}// 請求配置 | 請求體
const chunks = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10];/**
* 邏輯處理函數 | 如：發起請求
* @param {Object} chunk
* @returns {Promise} 
*/
const req = chunk => new Promise((res, rej) => setTimeout(_ => Math.random() > .8 ? rej('失敗----' + chunk) : res('結果' + chunk), Math.random() * 100 + 100))reqPool(req, chunks, 3, true).then(res => console.log(res))

運行圖