成人无码视频,亚洲精品久久久久av无码,午夜精品久久久久久毛片,亚洲 中文字幕 日韩 无码

資訊專欄INFORMATION COLUMN

Promise.all并發(fā)限制

sutaking / 1930人閱讀

摘要：并發(fā)限制指的是，每個(gè)時(shí)刻并發(fā)執(zhí)行的數(shù)量是固定的，最終的執(zhí)行結(jié)果還是保持與原來的一致。換句話說，就是把生成數(shù)組的控制權(quán)，交給并發(fā)控制邏輯。

背景

通常，我們?cè)谛枰ＷC代碼在多個(gè)異步處理之后執(zhí)行，會(huì)用到：

Promise.all(promises: []).then(fun: function);

Promise.all可以保證，promises數(shù)組中所有promise對(duì)象都達(dá)到resolve狀態(tài)，才執(zhí)行then回調(diào)。

這時(shí)候考慮一個(gè)場(chǎng)景：如果你的promises數(shù)組中每個(gè)對(duì)象都是http請(qǐng)求，或者說每個(gè)對(duì)象包含了復(fù)雜的調(diào)用處理。而這樣的對(duì)象有幾十萬個(gè)。

那么會(huì)出現(xiàn)的情況是，你在瞬間發(fā)出幾十萬http請(qǐng)求（tcp連接數(shù)不足可能造成等待），或者堆積了無數(shù)調(diào)用棧導(dǎo)致內(nèi)存溢出。

這時(shí)候，我們就需要考慮對(duì)Promise.all做并發(fā)限制。

Promise.all并發(fā)限制指的是，每個(gè)時(shí)刻并發(fā)執(zhí)行的promise數(shù)量是固定的，最終的執(zhí)行結(jié)果還是保持與原來的Promise.all一致。

實(shí)現(xiàn)

我們知道，promise并不是因?yàn)檎{(diào)用Promise.all才執(zhí)行，而是在實(shí)例化promise對(duì)象的時(shí)候就執(zhí)行了，在理解這一點(diǎn)的基礎(chǔ)上，要實(shí)現(xiàn)并發(fā)限制，只能從promise實(shí)例化上下手。

換句話說，就是把生成promises數(shù)組的控制權(quán)，交給并發(fā)控制邏輯。

這里我并不打算一步步實(shí)現(xiàn)這個(gè)這個(gè)功能，npm中有很多實(shí)現(xiàn)這個(gè)功能的第三方包，比如async-pool、es6-promise-pool、p-limit，這里我直接拿async-pool的代碼來分析一下實(shí)現(xiàn)原理。

代碼很簡(jiǎn)單，去掉不必要的代碼，加上自己的注釋，大概內(nèi)容如下：

function asyncPool(poolLimit, array, iteratorFn) {
    let i = 0;
    const ret = [];
    const executing = [];
    const enqueue = function () {
        // 邊界處理，array為空數(shù)組
        if (i === array.length) {
            return Promise.resolve();
        }
        // 每調(diào)一次enqueue，初始化一個(gè)promise
        const item = array[i++];
        const p = Promise.resolve().then(() => iteratorFn(item, array));
        // 放入promises數(shù)組
        ret.push(p);
        // promise執(zhí)行完畢，從executing數(shù)組中刪除
        const e = p.then(() => executing.splice(executing.indexOf(e), 1));
        // 插入executing數(shù)字，表示正在執(zhí)行的promise
        executing.push(e);
        // 使用Promise.rece，每當(dāng)executing數(shù)組中promise數(shù)量低于poolLimit，就實(shí)例化新的promise并執(zhí)行
        let r = Promise.resolve();
        if (executing.length >= poolLimit) {
            r = Promise.race(executing);
        }
        // 遞歸，直到遍歷完array
        return r.then(() => enqueue());
    };
    return enqueue().then(() => Promise.all(ret));
}

因?yàn)槭莗romise加上遞歸，所以在代碼注釋上不太好標(biāo)注執(zhí)行順序，但是大概的邏輯可以總結(jié)為：

從array第1個(gè)元素開始，初始化promise對(duì)象，同時(shí)用一個(gè)executing數(shù)組保存正在執(zhí)行的promise

不斷初始化promise，直到達(dá)到poolLimt

使用Promise.race，獲得executing中promise的執(zhí)行情況，當(dāng)有一個(gè)promise執(zhí)行完畢，繼續(xù)初始化promise并放入executing中

所有promise都執(zhí)行完了，調(diào)用Promise.all返回

使用方式就是：

const timeout = i => new Promise(resolve => setTimeout(() => resolve(i), i));
return asyncPool(2, [1000, 5000, 3000, 2000], timeout).then(results => {
    ...
});
總結(jié)

所謂promise并發(fā)限制，其實(shí)根源上就是控制promise的實(shí)例化。如果是通過第三方函數(shù)，那么就把創(chuàng)建promise的控制權(quán)交給第三方即可。

然而這樣的實(shí)現(xiàn)效果，本質(zhì)上來說已經(jīng)拋棄了Promise.all而另辟蹊徑。所以期待有一天promise標(biāo)準(zhǔn)能提供這個(gè)功能

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://m.hztianpu.com/yun/97763.html

相關(guān)文章

  • 小程序圖片合成：異步并發(fā)渲染→同步阻塞渲染

    摘要：故事開始了，小程序圖片合成真機(jī)測(cè)試時(shí)，會(huì)報(bào)錯(cuò)。所以只能將異步并發(fā)改為同步阻塞式渲染。 showImg(https://segmentfault.com/img/remote/1460000013228074); 故事開始了，小程序canvas圖片合成 真機(jī)測(cè)試時(shí)，會(huì)報(bào)錯(cuò)：getImageInfo failed 。也就是說，我這邊異步請(qǐng)求50張圖片，每張圖片都是通過getImageInf...

    zhoutao 評(píng)論0 收藏0

  • async/await 異步應(yīng)用的常用場(chǎng)景

    摘要：下面將簡(jiǎn)單地描述一下一些日常常用場(chǎng)景加深對(duì)認(rèn)識(shí)最普遍的異步操作就是請(qǐng)求我們也可以用來簡(jiǎn)單模擬異步請(qǐng)求。其中是必須的如果省略了程序就不能按預(yù)期得到結(jié)果。 前言 async/await 語法用看起來像寫同步代碼的方式來優(yōu)雅地處理異步操作,但是我們也要明白一點(diǎn),異步操作本來帶有復(fù)雜性,像寫同步代碼的方式并不能降低本質(zhì)上的復(fù)雜性,所以在處理上我們要更加謹(jǐn)慎, 稍有不慎就可能寫出不是預(yù)期執(zhí)行的代...

    ermaoL 評(píng)論0 收藏0

  • async/await 異步應(yīng)用的常用場(chǎng)景

    摘要：下面將簡(jiǎn)單地描述一下一些日常常用場(chǎng)景加深對(duì)認(rèn)識(shí)最普遍的異步操作就是請(qǐng)求我們也可以用來簡(jiǎn)單模擬異步請(qǐng)求。其中是必須的如果省略了程序就不能按預(yù)期得到結(jié)果。 前言 async/await 語法用看起來像寫同步代碼的方式來優(yōu)雅地處理異步操作,但是我們也要明白一點(diǎn),異步操作本來帶有復(fù)雜性,像寫同步代碼的方式并不能降低本質(zhì)上的復(fù)雜性,所以在處理上我們要更加謹(jǐn)慎, 稍有不慎就可能寫出不是預(yù)期執(zhí)行的代...

    darkbug 評(píng)論0 收藏0

  • async/await 異步應(yīng)用的常用場(chǎng)景

    摘要：下面將簡(jiǎn)單地描述一下一些日常常用場(chǎng)景加深對(duì)認(rèn)識(shí)最普遍的異步操作就是請(qǐng)求我們也可以用來簡(jiǎn)單模擬異步請(qǐng)求。其中是必須的如果省略了程序就不能按預(yù)期得到結(jié)果。 前言 async/await 語法用看起來像寫同步代碼的方式來優(yōu)雅地處理異步操作,但是我們也要明白一點(diǎn),異步操作本來帶有復(fù)雜性,像寫同步代碼的方式并不能降低本質(zhì)上的復(fù)雜性,所以在處理上我們要更加謹(jǐn)慎, 稍有不慎就可能寫出不是預(yù)期執(zhí)行的代...

    寵來也 評(píng)論0 收藏1

  • 多個(gè)請(qǐng)求并發(fā)執(zhí)行怎么寫？

    摘要：最近在寫一個(gè)程序，功能是下載頁面上的資源，首先拿到頁面資源鏈接列表，如要求是資源并行下載，所有資源下載結(jié)束后通知，收集錯(cuò)誤的下載鏈接。如果把上面模擬請(qǐng)求的注釋去掉，還會(huì)發(fā)現(xiàn)是在結(jié)束后就執(zhí)行了，而后面的請(qǐng)求還未結(jié)束。 最近在寫一個(gè)Node.js程序，功能是下載頁面上的資源，首先拿到頁面資源鏈接列表，如： [ https://xxx.com/img/logo.jpg, https:...

    gself 評(píng)論0 收藏0

發(fā)表評(píng)論

0條評(píng)論

閱讀需要支付1元查看
<