题目描述
JS实现一个带并发限制的异步调度器scheduler，保证同时运行的任务最多有两个。
例如目前有4个任务，完成时间分别为，1000ms,500ms,300ms,400ms
那么在该调度器中的执行完成顺序应该为2、3、1、4.
因为1、2先进入队列中，2完成则输出2，3进入，3完成输出3，此时为800ms，4进入后的200ms，1完成输出1，而后4完成输出4.
实现最多两个任务同时运行。
代码调用模板大概是：
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即可)
})
}
emmmmm我先来分析下....刚看这题有点懵，
通俗点：有个只能同时执行俩任务的队列，正在以每time秒执行这些任务，且任务按照顺序进入队列。
那，同时运行的任务不能超过两个，是不是每次运行一个任务时就放进数组中，判断任务的length是否小于2，在大于0且小于2的情况下就即刻执行该promise函数。
欸嘿，那运行两个任务的时候怎么办？要对promise函数进行一个选型，不能用一般的promise.then咯，在这同时运行的两个任务中需要有一个先后判断，哪个先执行完，需要下一个任务接替执行的，所以这当中存在一个“竞赛”关系，选择使用promise.race咯。（ps:这俩任务给我卷起来！！！！）
确认一下捏，有一个任务在队列中的情况时，只需要执行该任务，and执行完从队列中删除就好了。
but有两个的时候就要判断辽，只要队列中的size等于/大于2，就要进行promise.race的赛跑执行，finally执行完再去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出个结果再继续放下一个(doge)卷起来
const queueArr = []
this.queue.forEach(item => queueArr.push(item)) // 放进数组中~
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叭~
