調(diào)用then的時候，如果異步任務(wù)已完成則執(zhí)行成功或失敗的回調(diào)，否則掛起隊列。當(dāng)promise狀態(tài)改變的時候，調(diào)用掛起的隊列，執(zhí)行傳入的then的回調(diào)函數(shù)。

    // promise本質(zhì)：狀態(tài)機
    // 1.當(dāng)狀態(tài)改變的時候，調(diào)用之前掛起的then隊列
    // 2.then的時候執(zhí)行對應(yīng)的函數(shù) 并傳參
    class MyPromise {
      constructor(fn) {
        this.res = null
        this.err = null
        this._status = 'pending' // 當(dāng)前異步任務(wù)的執(zhí)行狀態(tài)
        this._queue = [] // 等待隊列

        fn((res) => { // 異步任務(wù)成功時用戶自主調(diào)用
          // console.log('成功');
          this.res = res
          this.status = 'resolved'

          this._queue.length && this._queue.forEach(item => { // 如果等待隊列不為空 則調(diào)用傳入的成功回調(diào)
            item.fn1(res)
          })
        }, (err) => { // 異步任務(wù)失敗時用戶自主調(diào)用
          // console.log('失敗');
          this.err = err
          this.status = 'rejected'

          this._queue.length && this._queue.forEach(item => { // 如果等待隊列不為空 則調(diào)用傳入的失敗回調(diào)
            item.fn2(res)
          })
        })
      }

      static all(arr) {
        let results = []
        return new MyPromise((resolve, reject) => {
          let i = 0
          next()

          function next() {
            arr[i].then((res) => {
              results.push(res)
              i++
              if (i === arr.length) {
                resolve(results)
              } else {
                next()
              }
            }, (err) => {
              reject(err)
            })
          }
        })
      }

      then(fn1, fn2) {
        // console.log('then');
        if (this.status === 'resolved') { // 執(zhí)行then的時候異步任務(wù)已完成--狀態(tài)為成功
          fn1(this.res)
        } else if (this.status === 'rejected') { // 執(zhí)行then的時候異步任務(wù)已完成--狀態(tài)為失敗
          fn2(this.err)
        } else { // 執(zhí)行then的時候異步任務(wù)未完成
          this._queue.push({fn1, fn2})
        }
        // console.log('等待隊列', this._queue);
      }
    }




    // test
    let p1 = new MyPromise((resolve, reject) => {
      setTimeout(() => {
        resolve(1)
      }, 1000);
    })
    let p2 = new MyPromise((resolve, reject) => {
      setTimeout(() => {
        resolve(2)
      }, 1000);
    })
    p1.then((res) => {
      console.log('成功回調(diào)==>', res);
    }, (err) => {
      console.log('失敗回調(diào)==>', err);
    })

    MyPromise.all([p1, p2]).then((res) => {
      console.log('all', res);
    }, (err) => {
      console.log('all', err);
    })