1. /*
    2.     题设：JS 实现一个带并发限制的异步调度器 Scheduler，保证同时运行的任务最多有两个
    3.     举例如下：
    4.          addTask(1000,"1");
    5.          addTask(500,"2");
    6.          addTask(300,"3");
    7.          addTask(400,"4");
    8.          的输出顺序是：2 3 1 4
    10.          整个的完整执行流程：
    11.         一开始1、2两个任务开始执行
    12.         500ms时，2任务执行完毕，输出2，任务3开始执行
    13.         800ms时，3任务执行完毕，输出3，任务4开始执行
    14.         1000ms时，1任务执行完毕，输出1，此时只剩下4任务在执行
    15.         1200ms时，4任务执行完毕，输出4
    16. */
    17. // 休眠函数
    18. var asleep = time => new Promise((resolve) => {
    19.     setTimeout(resolve, time)
    20. })
    21. class Scheduler {
    22.     constructor(limit) {
    23.         this.maxLimit = limit // 最多同时运行数量
    24.         this.runCount = 0 // 当前正在运行任务个数
    25.         this.queue = [] // 运行任务队列
    26.     }
    27.     // 添加任务方法
    28.     add(promiseCreator) {
    29.         this.queue.push(promiseCreator)
    30.     }
    32.     // 启动任务入口函数
    33.     taskStart() {
    34.         for(let i = 0; i < this.maxLimit; i++) {
    35.             this.request()
    36.         }
    37.     }
    39.     // 真正调用异步调度方法，自身调用自身，循环执行，直到符合终止条件
    40.     request() {
    41.         // 终止条件
    42.         if(!this.queue || !this.queue.length || this.runCount >= this.maxLimit) {
    43.             return
    44.         }
    45.         // 增加当前运行任务个数
    46.         this.runCount++
    47.         // console.log('runCount: ', this.runCount)
    49.         // 队列头部任务运行
    50.         const promiseTask = this.queue.shift()
    51.         promiseTask().then(() => {
    52.             // 减少当前运行任务个数
    53.             this.runCount--
    54.             this.request()
    55.         })
    56.     }
    57. }
    59. // 调用
    60. var scheduler = new Scheduler(2)
    61. var addTask = (time, order) => {
    62.     scheduler.add(
    63.         () => asleep(time).then(() => {
    64.             console.log('order: ', order)
    65.         })
    66.     )
    67. }
    68. addTask(1000,"1")
    69. addTask(500,"2")
    70. addTask(300,"3")
    71. addTask(400,"4")
    72. // 启动任务
    73. scheduler.taskStart()

    思路：
    1：有个空队列数组 queue；
    2：将所有待执行请求任务塞进 queue 队列中；
    3：调用入口函数 taskStart，并由函数中的 for 循环控制开始时的并发数量；
    4：调用请求函数 request，当有个 request 函数异步完成时，通过监听，在 then 方法中再次调用
    request 方法，从 queue 队列中，取出队头请求任务执行。
    参考：JavaScript 中如何实现并发控制？、Promise的并发控制