js 多个异步的并发控制

摘要:请实现如下的函数,可以批量请求数据,所有的URL地址在urls参数中,同时可以通过max参数 控制请求的并发度。当所有的请求结束后,需要执行callback回调。发请求的函数可以直接使用fetch。

请实现如下的函数,可以批量请求数据,所有的URL地址在urls参数中,同时可以通过max参数 控制请求的并发度。当所有的请求结束后,需要执行callback回调。发请求的函数可以直接使用fetch。

function sendRequest (urls: string[], max: number, callback: () => void) {

}


fetch 函数返回的是一个promise,promise对象在实例化的时候就已经开始执行了

function sendRequest(urls, max, callback) {
        let allUrls = [...urls],
            i = 0,
            fetchArr = [];
        
        function doFetch() {
            // 处理边界的情况
            if (i === allUrls.length) {
                return Promise.resolve();
            }
            //每次调用出去 一个 url, 放入fetch中
            let one = fetch(allUrls[i++]);
            // 将此promise的状态保存在fetchArr中, 执行完之后 从数组中删除。
            let result = one.then(() => fetchArr.splice(fetchArr.indexOf(result), 1));
            result.push(fetchArr);

            // 数量不够就重复调用doFetch, 够了的话就比较
            let p = Promise.resolve();
            if (fetchArr.length >= max) {
                p = Promise.race(fetchArr);
            }
            return p.then(() => doFetch())
        }
        // 最后用all 处理剩余数组中的,等处理完再执行callback
        return doFetch().then(() => Promise.all(fetchArr)).then(() => {
            callback();
        })
    }


本文内容仅供个人学习、研究或参考使用,不构成任何形式的决策建议、专业指导或法律依据。未经授权,禁止任何单位或个人以商业售卖、虚假宣传、侵权传播等非学习研究目的使用本文内容。如需分享或转载,请保留原文来源信息,不得篡改、删减内容或侵犯相关权益。感谢您的理解与支持!

链接: https://shenqiku.cn/article/FLY_2400