題目描述

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

例如目前有4個任務，完成時間分別為，1000ms,500ms,300ms,400ms

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

因為1、2先進入隊列中，2完成則輸出2，3進入，3完成輸出3，此時為800ms，4進入后的200ms，1完成輸出1，而后4完成輸出4.

實現(xiàn)最多兩個任務同時運行。

代碼調用模板大概是：

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

emmmmm我先來分析下....剛看這題有點懵，

通俗點：有個只能同時執(zhí)行倆任務的隊列，正在以每time秒執(zhí)行這些任務，且任務按照順序進入隊列。

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

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

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

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

就醬紫，寫代碼叭~

class Scheduler{
  queue = new Set<Promise<any>>() //去重的promise隊列~
  add(promiseCreator:()=>Promose<any>){ //每次用來加任務的方法~~
      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個任務 就開始race這倆任務
      // race出個結果再繼續(xù)放下一個(doge)卷起來
      const queueArr = []
      this.queue.forEach(item => queueArr.push(item)) // 放進數(shù)組中~
      return Promise.race(queueArr).finally(this.add(promiseCreator))
  }
}

get!,最后再調用下可以查看結果啦。

addTask(1000,1)
addTask(500,2)
addTask(300,3)
addTask(400,4)

快看看是不是2、3、1、4叭~

到此這篇關于基于JS實現(xiàn)帶并發(fā)限制的異步調度器的文章就介紹到這了,更多相關JS異步調度器內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！