牛客网题目:
JS实现一个带并发限制的异步调度器Scheduler,保证同时运行的任务最多有两个。完善代码中Scheduler类,使得以下程序能正确输出。
// 基础代码class Scheduler {add(promiseCreator) { ... }// ...}const timeout = (time) => new Promise(resolve => {setTimeout(resolve, time)})const scheduler = new Scheduler()const addTask = (time, order) => {scheduler.add(() => timeout(time)).then(() => console.log(order))}addTask(1000, '1')addTask(500, '2')addTask(300, '3')addTask(400, '4')// output: 2 3 1 4// 一开始,1、2两个任务进入队列// 500ms时,2完成,输出2,任务3进队// 800ms时,3完成,输出3,任务4进队// 1000ms时,1完成,输出1// 1200ms时,4完成,输出4
答案:
class Scheduler {constructor() {this.taskArr = []this.count = 0}add(promiseCreator) {return new Promise((resolve, reject) => {this.taskArr.push({promiseCreator, resolve})this.run()})}run() {if(this.taskArr.length && this.count < 2) {this.count ++let {promiseCreator, resolve} = this.taskArr.shift()Promise.resolve(promiseCreator()).then(() => {resolve()this.count --this.run()})}}}const timeout = (time) => new Promise(resolve => {setTimeout(resolve, time)})const scheduler = new Scheduler()const addTask = (time, order) => {scheduler.add(() => timeout(time)).then(() => console.log(order))}addTask(1000, '1')addTask(500, '2')addTask(300, '3')addTask(400, '4')// output: 2 3 1 4// 一开始,1、2两个任务进入队列// 500ms时,2完成,输出2,任务3进队// 800ms时,3完成,输出3,任务4进队// 1000ms时,1完成,输出1// 1200ms时,4完成,输出4// 保证同时运行的任务最多有两个a
