欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

js Promise并發(fā)控制數(shù)量的方法

 更新時(shí)間:2021年08月26日 15:24:07   作者:Leon  
在業(yè)務(wù)開(kāi)發(fā)過(guò)程中,我們經(jīng)常會(huì)遇到多個(gè)異步任務(wù)并發(fā)執(zhí)行的情況,待所有異步任務(wù)結(jié)束之后再執(zhí)行我們的業(yè)務(wù)邏輯,那么js Promise并發(fā)控制數(shù)量是多少,本文就來(lái)介紹一下

問(wèn)題

要求寫(xiě)一個(gè)方法控制 Promise 并發(fā)數(shù)量,如下:

promiseConcurrencyLimit(limit, array, iteratorFn)

limit 是同一時(shí)間執(zhí)行的 promise 數(shù)量,array 是參數(shù)數(shù)組,iteratorFn 每個(gè) promise 中執(zhí)行的異步操作。

背景

開(kāi)發(fā)中需要在多個(gè)promise處理完成后執(zhí)行后置邏輯,通常使用Promise.all:

Primise.all([p1, p2, p3]).then((res) => ...)

但是有個(gè)問(wèn)題是,因?yàn)?promise 創(chuàng)建后會(huì)立即執(zhí)行,也就是說(shuō)傳入到 promise.all 中的多個(gè) promise 實(shí)例,在其創(chuàng)建的時(shí)候就已經(jīng)開(kāi)始執(zhí)行了,如果這些實(shí)例中執(zhí)行的異步操作都是 http 請(qǐng)求,那么就會(huì)在瞬間發(fā)出 n 個(gè) http 請(qǐng)求,這樣顯然是不合理的;更合理的方式是:對(duì) Promise.all 中異步操作的執(zhí)行數(shù)量加以限制,同一時(shí)間只允許有 limit 個(gè)異步操作同時(shí)執(zhí)行。

思路 & 實(shí)現(xiàn)

在背景中提到,promise 在創(chuàng)建后就會(huì)立即執(zhí)行,所以控制并發(fā)的核心在于控制 promise 實(shí)例的生成。最開(kāi)始只生成 limit 個(gè) promise 實(shí)例,然后等待這些 promise 狀態(tài)變更,只要其中某一個(gè) promise 實(shí)例的狀態(tài)發(fā)生變更,就立即再創(chuàng)建一個(gè) promise 實(shí)例...如此循環(huán),直到所有的 promise 都被創(chuàng)建并執(zhí)行。

npm 上有很多庫(kù)實(shí)現(xiàn)了此功能,個(gè)人覺(jué)得 tiny-async-pool 這個(gè)庫(kù)比較好,因?yàn)樗苯邮褂昧嗽?Promise 實(shí)現(xiàn)了此功能,而其他庫(kù)大多重新實(shí)現(xiàn)了 promise。其核心代碼如下:

async function asyncPool(poolLimit, array, iteratorFn) {
  const ret = []; // 用于存放所有的promise實(shí)例
  const executing = []; // 用于存放目前正在執(zhí)行的promise
  for (const item of array) {
    const p = Promise.resolve(iteratorFn(item)); // 防止回調(diào)函數(shù)返回的不是promise,使用Promise.resolve進(jìn)行包裹
    ret.push(p);
    if (poolLimit <= array.length) {
      // then回調(diào)中,當(dāng)這個(gè)promise狀態(tài)變?yōu)閒ulfilled后,將其從正在執(zhí)行的promise列表executing中刪除
      const e = p.then(() => executing.splice(executing.indexOf(e), 1));
      executing.push(e);
      if (executing.length >= poolLimit) {
        // 一旦正在執(zhí)行的promise列表數(shù)量等于限制數(shù),就使用Promise.race等待某一個(gè)promise狀態(tài)發(fā)生變更,
        // 狀態(tài)變更后,就會(huì)執(zhí)行上面then的回調(diào),將該promise從executing中刪除,
        // 然后再進(jìn)入到下一次for循環(huán),生成新的promise進(jìn)行補(bǔ)充
        await Promise.race(executing);
      }
    }
  }
  return Promise.all(ret);
}

測(cè)試代碼如下:

const timeout = (i) => {
  console.log('開(kāi)始', i);
  return new Promise((resolve) => setTimeout(() => {
    resolve(i);
    console.log('結(jié)束', i);
  }, i));
};

(async () => {
    const res = await asyncPool(2, [1000, 5000, 3000, 2000], timeout);
    console.log(res);
  })();

代碼的核心思路為:

  • 先初始化 limit 個(gè) promise 實(shí)例,將它們放到 executing 數(shù)組中
  • 使用 Promise.race 等待這 limit 個(gè) promise 實(shí)例的執(zhí)行結(jié)果
  • 一旦某一個(gè) promise 的狀態(tài)發(fā)生變更,就將其從 executing 中刪除,然后再執(zhí)行循環(huán)生成新的 promise,放入executing 中
  • 重復(fù)2、3兩個(gè)步驟,直到所有的 promise 都被執(zhí)行完
  • 最后使用 Promise.all 返回所有 promise 實(shí)例的執(zhí)行結(jié)果

到此這篇關(guān)于js Promise并發(fā)控制數(shù)量的方法的文章就介紹到這了,更多相關(guān)js Promise并發(fā)控制內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • bootstrap table支持高度百分比的實(shí)例代碼

    bootstrap table支持高度百分比的實(shí)例代碼

    這篇文章給大家介紹了bootstrap table支持高度百分比的實(shí)例代碼,通過(guò)更改BootstrapTable.prototype.resetView 方法,以支持高度百分比定義,適應(yīng)不同高度屏幕,感興趣的朋友跟隨腳本之家小編一起學(xué)習(xí)吧
    2018-02-02
  • js返回上一頁(yè)并刷新代碼整理

    js返回上一頁(yè)并刷新代碼整理

    返回上一頁(yè)并刷新在此功能有利于用戶的體驗(yàn),是每一個(gè)web開(kāi)發(fā)人員所必備的一項(xiàng),長(zhǎng)話短說(shuō),今天介紹實(shí)現(xiàn)此功能的一個(gè)方法,需要了解的朋友可以參考下
    2012-12-12
  • 解決canvas畫(huà)布使用fillRect()時(shí)高度出現(xiàn)雙倍效果的問(wèn)題

    解決canvas畫(huà)布使用fillRect()時(shí)高度出現(xiàn)雙倍效果的問(wèn)題

    下面小編就為大家?guī)?lái)一篇解決canvas畫(huà)布使用fillRect()時(shí)高度出現(xiàn)雙倍效果的問(wèn)題。小編覺(jué)得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧
    2017-08-08
  • bootstrap下拉列表與輸入框組結(jié)合的樣式調(diào)整

    bootstrap下拉列表與輸入框組結(jié)合的樣式調(diào)整

    輸入框組默認(rèn)是div.input-group。接下來(lái)通過(guò)本文給大家介紹bootstrap下拉列表與輸入框組結(jié)合的樣式調(diào)整,感興趣的朋友一起看看吧
    2016-10-10
  • JavaScript實(shí)現(xiàn)密碼框驗(yàn)證信息

    JavaScript實(shí)現(xiàn)密碼框驗(yàn)證信息

    這篇文章主要為大家詳細(xì)介紹了JavaScript實(shí)現(xiàn)密碼框驗(yàn)證信息,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2021-11-11
  • JS仿QQ好友列表展開(kāi)、收縮功能(第一篇)

    JS仿QQ好友列表展開(kāi)、收縮功能(第一篇)

    這篇文章主要介紹了JS仿QQ好友列表展開(kāi)、收縮功能(第一篇),需要的朋友可以參考下
    2017-07-07
  • JS實(shí)現(xiàn)設(shè)置ff與ie元素絕對(duì)位置的方法

    JS實(shí)現(xiàn)設(shè)置ff與ie元素絕對(duì)位置的方法

    這篇文章主要介紹了JS實(shí)現(xiàn)設(shè)置ff與ie元素絕對(duì)位置的方法,涉及JavaScript針對(duì)頁(yè)面元素及元素屬性的相關(guān)操作技巧,需要的朋友可以參考下
    2016-03-03
  • js 函數(shù)性能比較方法

    js 函數(shù)性能比較方法

    在學(xué)習(xí)js過(guò)程中,經(jīng)常會(huì)遇到同樣一個(gè)功能點(diǎn) 這樣實(shí)現(xiàn)也可以,那樣實(shí)現(xiàn)也可以。但是哪個(gè)方式最優(yōu)呢
    2020-08-08
  • JavaScript設(shè)計(jì)模式之單體模式全面解析

    JavaScript設(shè)計(jì)模式之單體模式全面解析

    單體模式可以說(shuō)是javascript中最基本也是最有用的模式之一,接下來(lái)通過(guò)本文給大家解析js設(shè)計(jì)模式之單體模式,非常不錯(cuò),感興趣的朋友一起看看吧
    2016-09-09
  • JavaScript實(shí)現(xiàn)帶標(biāo)題的圖片輪播特效

    JavaScript實(shí)現(xiàn)帶標(biāo)題的圖片輪播特效

    這里給大家分享的是4屏帶標(biāo)題和文字描述的js圖片輪播代碼,完美兼容IE6。圖片滾動(dòng)切換,鼠標(biāo)放到數(shù)字選項(xiàng)卡即可切換圖片。點(diǎn)擊圖片跳轉(zhuǎn)到指定頁(yè)面,有需要的小伙伴可以參考下。
    2015-05-05

最新評(píng)論