JS 實作一個帶并發限制的異步調度器 Scheduler，保證同時運行的任務最多有兩個
addTask(1000,"1");
addTask(500,"2");
addTask(300,"3");
addTask(400,"4");
的輸出順序是：2 3 1 4
整個的完整執行流程：
一開始1、2兩個任務開始執行
500ms時，2任務執行完畢，輸出2，任務3開始執行
800ms時，3任務執行完畢，輸出3，任務4開始執行
1000ms時，1任務執行完畢，輸出1，此時只剩下4任務在執行
1200ms時，4任務執行完畢，輸出4
作者：Big shark@LX
鏈接：https://juejin.cn/post/6968713283884974088
來源：掘金
著作權歸作者所有，商業轉載請聯系作者獲得授權，非商業轉載請注明出處，class Scheduler {
constructor(limit) {
this.queue = [];
this.maxCount = limit;
this.runCounts = 0;
}
add(time, order) {
const promiseCreator = () => {
return new Promise((resolve, reject) => {
setTimeout(() => {
console.log(order);
resolve();
}, time);
});
};
this.queue.push(promiseCreator);
}
taskStart() {
for (let i = 0; i < this.maxCount; i++) {
this.request();
}
}
request() {
if (!this.queue || !this.queue.length || this.runCounts >= this.maxCount) {
return;
}
this.runCounts++;
this.queue
.shift()()
.then(() => {
this.runCounts--;
this.request();
});
}
}
const scheduler = new Scheduler(2);
const addTask = (time, order) => {
scheduler.add(time, order);
};
addTask(1000, "1");
addTask(500, "2");
addTask(300, "3");
addTask(400, "4");
scheduler.taskStart();
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/286534.html
標籤：其他
上一篇：中科微CI24R1超低成本2.4G無線收發芯片替代XN297支持BLE4.2
下一篇：4G物聯卡跟NB物聯卡有什么區別