基于JS實(shí)現(xiàn)帶并發(fā)限制的異步調(diào)度器

更新時(shí)間：2023年05月12日 08:19:57 作者：霍格沃茨魔法師

這篇文章主要為大家詳細(xì)介紹了如何基于JS實(shí)現(xiàn)帶并發(fā)限制的異步調(diào)度器，文中的示例代碼講解詳細(xì)，具有一定的學(xué)習(xí)價(jià)值，需要的可以參考下

題目描述

JS實(shí)現(xiàn)一個(gè)帶并發(fā)限制的異步調(diào)度器scheduler，保證同時(shí)運(yùn)行的任務(wù)最多有兩個(gè)。

例如目前有4個(gè)任務(wù)，完成時(shí)間分別為，1000ms,500ms,300ms,400ms

那么在該調(diào)度器中的執(zhí)行完成順序應(yīng)該為2、3、1、4.

因?yàn)?、2先進(jìn)入隊(duì)列中，2完成則輸出2，3進(jìn)入，3完成輸出3，此時(shí)為800ms，4進(jìn)入后的200ms，1完成輸出1，而后4完成輸出4.

實(shí)現(xiàn)最多兩個(gè)任務(wù)同時(shí)運(yùn)行。

代碼調(diào)用模板大概是：

class Scheduler{
    add(promiseCreator){.....}
}
// 設(shè)置一個(gè)以每time秒執(zhí)行異步任務(wù)的定時(shí)器
const timeout = (time) => {
  new Promise(resolve => {
    setTimeout(resolve,time)
  })
}
// 實(shí)例
const scheduler = new Scheduler()
const addTask = (time,order)=>{
    scheduler.add(()=>{ //調(diào)用實(shí)例的方法
        timeout(time) //每time秒執(zhí)行一下任務(wù)(其實(shí)每一秒就行->time=1000ms即可)
    })
}

emmmmm我先來分析下....剛看這題有點(diǎn)懵，

通俗點(diǎn)：有個(gè)只能同時(shí)執(zhí)行倆任務(wù)的隊(duì)列，正在以每time秒執(zhí)行這些任務(wù)，且任務(wù)按照順序進(jìn)入隊(duì)列。

那，同時(shí)運(yùn)行的任務(wù)不能超過兩個(gè)，是不是每次運(yùn)行一個(gè)任務(wù)時(shí)就放進(jìn)數(shù)組中，判斷任務(wù)的length是否小于2，在大于0且小于2的情況下就即刻執(zhí)行該promise函數(shù)。

欸嘿，那運(yùn)行兩個(gè)任務(wù)的時(shí)候怎么辦？要對promise函數(shù)進(jìn)行一個(gè)選型，不能用一般的promise.then咯，在這同時(shí)運(yùn)行的兩個(gè)任務(wù)中需要有一個(gè)先后判斷，哪個(gè)先執(zhí)行完，需要下一個(gè)任務(wù)接替執(zhí)行的，所以這當(dāng)中存在一個(gè)“競賽”關(guān)系，選擇使用promise.race咯。（ps:這倆任務(wù)給我卷起來?。。。。?/p>

確認(rèn)一下捏，有一個(gè)任務(wù)在隊(duì)列中的情況時(shí)，只需要執(zhí)行該任務(wù)，and執(zhí)行完從隊(duì)列中刪除就好了。

but有兩個(gè)的時(shí)候就要判斷遼，只要隊(duì)列中的size等于/大于2，就要進(jìn)行promise.race的賽跑執(zhí)行，finally執(zhí)行完再去add下一個(gè)(promise任務(wù))進(jìn)來接著卷~。

就醬紫，寫代碼叭~

class Scheduler{
  queue = new Set<Promise<any>>() //去重的promise隊(duì)列~
  add(promiseCreator:()=>Promose<any>){ //每次用來加任務(wù)的方法~~
      if(this.queue.size>0 && this.queue.size<2){
          const promise = promiseCreator()
          this.queue.add(promise)
          promise.finally(()=>{
              this.queue.delete(promise)
          })
          return promise
      }
      // 只要到了2個(gè)任務(wù) 就開始race這倆任務(wù)
      // race出個(gè)結(jié)果再繼續(xù)放下一個(gè)(doge)卷起來
      const queueArr = []
      this.queue.forEach(item => queueArr.push(item)) // 放進(jìn)數(shù)組中~
      return Promise.race(queueArr).finally(this.add(promiseCreator))
  }
}

get!,最后再調(diào)用下可以查看結(jié)果啦。