基于JS实现带并发限制的异步调度器

class Scheduler{
    add(promiseCreator){.....}
}
// 设置一个以每time秒执行异步任务的定时器
const timeout = (time) => {
  new Promise(resolve => {
    setTimeout(resolve,time)
  })
}
// 实例
const scheduler = new Scheduler()
const addTask = (time,order)=>{
    scheduler.add(()=>{ //调用实例的方法
        timeout(time) //每time秒执行一下任务(其实每一秒就行->time=1000ms即可)
    })
}

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出个结果再继续放下一个(doge)卷起来
      const queueArr = []
      this.queue.forEach(item => queueArr.push(item)) // 放进数组中~
      return Promise.race(queueArr).finally(this.add(promiseCreator))
  }
}