const delay = function delay(interval) {
      return new Promise((res,rej) => {
        setTimeout(() => {
          res(interval)
        }, interval);
      })
    }


    let tasks = [() => {
      return delay(1000)
    },() => {
      return delay(1003)
    },() => {
      return delay(1005)
    },() => {
      return delay(1002)
    },() => {
      return delay(1004)
    },() => {
      return delay(1006)
    }]

    // 通過Promise.all實(shí)現(xiàn)并行
    Promise.all(tasks.map(task => task())).then(res => {
      console.log(res);
    })

    // 基于Promise實(shí)現(xiàn)

    function creatRequest(tasks,pool) {
      // 每次控制的發(fā)送請(qǐng)求的數(shù)量pool
      pool = pool || 5
      // 用于存儲(chǔ)每一次請(qǐng)求的結(jié)果(按順序進(jìn)行存貯)
      let results = [],
      // together 用于創(chuàng)建工作區(qū)，當(dāng)pool傳入的是幾，我們就對(duì)應(yīng)的創(chuàng)建幾個(gè)工作區(qū)
      // 也就是創(chuàng)建一個(gè)長(zhǎng)度為pool且值為null的一個(gè)數(shù)組
          together = new Array(pool).fill(null),
      // index為每次獲取的任務(wù)值
          index = 0;
      together = together.map(() => {
        // 基于Promise進(jìn)行管理
        return new Promise((resolve,reject) => {
          // 創(chuàng)建一個(gè)函數(shù)，進(jìn)來立刻執(zhí)行
          const run = function run() {
            // 如果任務(wù)池已經(jīng)空了，說明請(qǐng)求發(fā)送完成了，直接成功
            if(index >= tasks.length) {
              resolve()
              return 
            }
            // 先將index保存一下用于存儲(chǔ)當(dāng)前成功請(qǐng)求的結(jié)果
            let old_index = index,
            // 獲取當(dāng)前發(fā)送的請(qǐng)求，然后把index進(jìn)行累加，所以上面會(huì)把index保存起來
            // 這里index++ 是先運(yùn)算后累加的，而++index則相反，先累加后運(yùn)算
                task = tasks[index++];
            // 執(zhí)行請(qǐng)求
            task().then(result => {
            // 將成功結(jié)果保存
              results[old_index] = result
            // 遞歸繼續(xù)執(zhí)行，也就是繼續(xù)拿到任務(wù)到工作區(qū)執(zhí)行
              run();
            }).catch(reason => {
              reject(reason)
            })
          }
          // 立即執(zhí)行
          run()
        })
      })
      // 用Promise.all管控工作區(qū)，也就是每次并發(fā)兩個(gè)請(qǐng)求
      return Promise.all(together).then(() => results)
    }


    creatRequest(tasks,2).then(results => {
      // 都成功，整體才成功，按順序存儲(chǔ)結(jié)果
      console.log('成功',results);
    }).catch(resolve => {
      // 只要有一個(gè)失敗，整體失敗
      console.log('失敗');
    })



    // 基于Class實(shí)現(xiàn)
    function creatRequest(tasks,pool,callback) {
      // 參數(shù)的限制與驗(yàn)證
      if(typeof pool === 'function') {
        callback = pool;
        pool = 5
      }
      if(typeof pool !== 'number') pool = 5
      if(typeof callback !== 'function') callback = function () {}
      // -------
      class TaskQueue {
        // 正在運(yùn)行的個(gè)數(shù)
        runing = 0;
        // 將所有任務(wù)所存在的隊(duì)列
        queue = [];
        // 存儲(chǔ)執(zhí)行任務(wù)(請(qǐng)求)的結(jié)果
        results = [];
        pushTask(task) {
          let self = this
          // 將任務(wù)推入工作區(qū)
          self.queue.push(task)
          // 執(zhí)行發(fā)送請(qǐng)求的邏輯
          self.next()
        }
        next() {
          let self = this
          // 當(dāng)正在執(zhí)行的任務(wù)數(shù)小于并發(fā)量的時(shí)候繼續(xù)去拿任務(wù)執(zhí)行
          while(self.runing < pool && self.queue.length) {
            self.runing++;
            // 相當(dāng)于拿一個(gè)任務(wù)刪除一個(gè)任務(wù)
            let task = self.queue.shift();
            // 執(zhí)行請(qǐng)求
            task().then(result => {
              // 將執(zhí)行結(jié)果保存
              self.results.push(result)
            }).finally(() => {
              // 將正在運(yùn)行的個(gè)數(shù)清除
              self.runing--
              // 繼續(xù)執(zhí)行請(qǐng)求
              self.next()
            })
          }
          // 當(dāng)沒有任務(wù)了循環(huán)結(jié)束
          if(self.runing === 0) callback(self.results)
        }


      }
      // 實(shí)例化
      let TQ = new TaskQueue()
      tasks.forEach(task => TQ.pushTask(task))
    }


    creatRequest(tasks,2,results=> {
      console.log(results);
    })