国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

淺談 Promise

李濤 / 2329人閱讀

摘要:解決異步編程有兩種主要方式事件模型和回調函數。將異步操作以同步操作的流程表達出來,避免了層層嵌套回調函數。方法是的別名,相當于函數的第一個參數傳入,第二個參數傳入發生錯誤時的回調函數。

JavaScript 解決異步編程有兩種主要方式:事件模型和回調函數。但是隨著業務越來越復雜,這兩種方式已經不能滿足開發者的需求了,Promise 可以解決這方面的問題。

為了更好的理解 Promise 是如何工作的,我們先來了解一下傳統的異步編程的方式。

異步編程的方式 1. 事件模型:
let button = document.getElementId("my-btn");
button.onclick = function() {
    console.log("Hello");
}

任務的執行不取決于代碼的順序,而取決于某個事件是否發生。上面代碼中,console.log("Hello") 直到 button 被點擊后才會被執行。當 button 被點擊,賦值給 onclick 的函數就被添加到作業隊列的尾部,并在隊列前部所有任務結束之后再執行。

事件模型適用于處理簡單的交互,若將多個獨立的異步調用連接在一起,必須跟蹤每個事件的事件目標,會使程序更加復雜,運行流程會變得很不清晰。

2. 回調函數

我們來看一下比較經典的使用 jsonp 解決跨域問題的示例:

function callback (res) {
  document.getElementById("d1").innerHTML = res.result.address
  console.log("Your public IP address is: ", res)
}
function jsonp (lat, lng) {
  let src = `https://apis.map.qq.com/ws/geocoder/v1/?location=${lat},${lng}&key=yourKey&output=jsonp&callback=callback`
  let script = document.createElement("script")
  script.setAttribute("type","text/javascript")
  script.src = src;
  document.body.appendChild(script)
}
jsonp(39.92, 116.43)

初看這種模式運作得相當好,簡單、容易理解,但你可能會迅速的發現這樣的模式不利于代碼的閱讀和維護,各個部分之間耦合度太高,容易陷入回調地獄。就像這樣:

method1(function(err, result) {
  if (err) {
    throw err
  }

  method2(function(err, result) {
    if (err) {
      throw err
    }

    method3(function(err, result) {
      if (err) {
        throw err
      }

      method4(function(err, result) {
        if (err) {
          throw err
        }

        method5(result)
      })
    })
  })
})

Promise 能大幅度改善這種情況。我們來看下Promise 是如何實現的:

let promise = new Promise((resolve, reject) => {
  // ... method 1 some code

  if (/* 異步操作成功 */){
    resolve(value);
  } else {
    reject(error);
  }
})
promise.then((value) => {
  // method 2 some code
}).then((value) => {
  // method 3 some code
}).then((value) => {
  // method 4 some code
}).then((value) => {
  // method 5 some code
}).catch((err) => {
  // some err code
})

是不是清晰很多?是不是很神奇?接下來一起來學習一下 Promise 吧!

Promise 相關知識 1. Promise 的基礎知識

我們先來看下 Promise 的方法有哪些:

Promise.Prototype.then()
Promise.Prototype.catch()
Promise.Prototype.finally()
Promise.all()
Promise.race()
Promise.resolve()
Promise.reject()
Promise.try()

Promise 函數的執行,都是依賴于狀態的改變,這三種狀態要記牢哦:

Pending:進行中
Fulfilled:已成功
Rejected:已失敗

Promise 優點:

1)對象的狀態不受外界影響。
2)一旦狀態改變,就不會再變,任何時候都可以得到這個結果。
3)將異步操作以同步操作的流程表達出來,避免了層層嵌套回調函數。
4)提供統一的接口,使得控制異步操作更加容易。

Promise 缺點:

1)無法取消 Promise,一旦新建它就會立即執行,無法中途取消。
2)如果不設置回調函數,Promise 內部拋出的錯誤,不會反映到外部。
3)當處于 pending 狀態時,無法得知目前進展到哪一個階段(剛剛開始還是即將完成)。

了解了 Promise 的方法,3種狀態以及特點和優缺點之后,接下來我們來看一下 Promise 是怎么使用的。

2. Promise 的基本用法

我們來創造一個讀取文件的 Promise 實例:

const fs = require("fs")
const path = require("path")

function readFile (filename) {
  return new Promise (function (resolve, reject) {
    // reject(new Error("err"))
    //觸發異步操作
    fs.readFile(filename, {encoding: "utf8"}, function (err, contents) {

      // 檢查錯誤
      if (err) {
        reject(err)
        return
      }

      //讀取成功
      resolve(contents)
    })
  })
}
let promise = readFile(path.resolve(__dirname, "../json/a.json"))

上述實例中 resolve 函數的作用是,將 Promise 對象的狀態從“未完成”變為“成功”(即從 pending 變為 resolved),在異步操作成功時調用,并將異步操作的結果,作為參數傳遞出去;

reject 函數的作用是,將 Promise 對象的狀態從“未完成”變為“失敗”(即從 pending 變為 rejected),在異步操作失敗時調用,并將異步操作報出的錯誤,作為參數傳遞出去。

2.1 Promise.Prototype.then()

Promise 實例生成以后,就可以用 then 方法來分別指定 resolved 狀態和 rejected 狀態的回調函數了。

promise.then(function (contents) {
  // 完成
  console.log(contents)
  return(contents)
}, function (err) {
  // 失敗
  console.log(err.message)
})

我們可以看到,then 方法接受兩個回調函數作為參數;
第一個回調函數在 Promise 對象的狀態變為 resolved 時調用;
第二個回調函數在 Promise 對象的狀態變為 rejected 時調用;
其中,第二個函數是可選的。這兩個函數都接受 Promise 對象傳出的值作為參數。

Promise.then 方法每次調用,都返回一個新的 Promise 對象,所以支持鏈式寫法。

let taskA = (value) => {
  console.log("Task A")
  console.log(value)
  return value
}

let taskB = (value) => {
  console.log("Task B")
  console.log(value)
}

promise
.then(taskA)
.then(taskB)
.catch((err) => {
  console.log(err.message)
})
2.2 Promise.Prototype.catch()

Promise.prototype.catch 方法是 .then(null, rejection) 的別名,相當于 then 函數的第一個參數傳入 null,第二個參數傳入發生錯誤時的回調函數。

promise.then(function(value) {
  // 成功
  console.log(value)
}).catch(function (err) {
  // 失敗
  console.log(err.message)
})
2.3 Promise.Prototype.finally()

finally 方法用于指定不管 Promise 對象最后狀態如何,都會執行的操作。該方法是 ES2018 引入標準的,目前大部分瀏覽器還不支持,不過可以自己實現。

finally 方法的實現:

Promise.prototype.finally = function (callback) {
  let P = this.constructor
  return this.then(
    value  => P.resolve(callback()).then(() => value),
    reason => P.resolve(callback()).then(() => { throw reason })
  )
}

finally 方法的使用:

promise
.then((contents) => {
  console.log(contents)
  return contents
})
.catch((err) => {
  console.log(err.message)
})
.finally(() => {
    console.log("finally")
})
2.4 Promise.all()

Promise.all 方法可以將多個 Promise 實例,包裝成一個新的 Promise 實例。

const p = Promise.all([p1, p2, p3]);

新的 Promise p 的狀態由 p1、p2、p3 決定,只有當 p1、p2、p3 的狀態都變成了 fulfilled,p 的狀態才會變成 fulfilled;只要 p1、p2、p3 之中有一個被 rejected,p 的狀態就變成了 rejected。

注意,如果作為參數的 Promise 實例,自己定義了 catch 方法,那么它一旦被 rejected,并不會觸發Promise.all()的 catch 方法的。

如果 p2 有自己的 catch 方法,就不會調用 Promise.all() 的 catch 方法。

const p1 = new Promise((resolve, reject) => {
  resolve("hello");
})
.then(result => result)
.catch(e => e);

const p2 = new Promise((resolve, reject) => {
  throw new Error("報錯了");
})
.then(result => result)
.catch(e => e);

Promise.all([p1, p2])
.then(result => console.log(result))
.catch(e => console.log(e));
// ["hello", Error: 報錯了]

如果 p2 沒有自己的 catch 方法,就會調用 Promise.all() 的 catch 方法。

const p1 = new Promise((resolve, reject) => {
  resolve("hello");
})
.then(result => result);

const p2 = new Promise((resolve, reject) => {
  throw new Error("報錯了");
})
.then(result => result);

Promise.all([p1, p2])
.then(result => console.log(result))
.catch(e => console.log(e));
// Error: 報錯了
2.5 Promise.race()

Promise.race 方法同樣是將多個 Promise 實例,包裝成一個新的 Promise 實例。

const p = Promise.race([p1, p2, p3]);

新的Promise p,只要 p1、p2、p3 之中有一個實例率先改變狀態,p 的狀態就跟著改變。那個率先改變的 Promise 實例的返回值,就傳遞給 p 的回調函數。

function timerPromisefy(delay) {
  return new Promise(function (resolve, reject) {
    setTimeout(function () {
      resolve(delay)
    }, delay)
  })
}

Promise.race([
  timerPromisefy(10),
  timerPromisefy(20),
  timerPromisefy(30)
]).then(function (values) {
  console.log(values) // 10
})
2.6 Promise.resolve()

有時需要將現有對象轉為 Promise 對象,Promise.resolve 方法就起到這個作用,返回一個 fulfilled 狀態的 Promise 對象。

const promise = Promise.resolve("hello");
promise.then(function(value){
    console.log(value);
});

// 相當于
const promise = new Promise(resolve => {
   resolve("hello");
});
promise.then((value) => {
  console.log(value)
})
2.7 Promise.reject()

Promise.reject(reason) 方法也會返回一個新的 Promise 實例,該實例的狀態為 rejected。

const p = Promise.reject("出錯了");
p.then(null, (value) => {
  console.log(value)
})

// 等同于
const p = new Promise((resolve, reject) => reject("出錯了"))
p.then(null, (value) => {
  console.log(value)
})
2.8 Promise.try()

讓同步函數同步執行,異步函數異步執行。

const f = () => console.log("now");
Promise.try(f);
console.log("next");
// now
// next
應用 異步加載圖片

實現方法:

function loadImageAsync(url) {
  return new Promise(function(resolve, reject) {
    const image = new Image()

    image.onload = function() {
      resolve(image)
    }

    image.onerror = function() {
      reject(new Error("Could not load image at " + url))
    }

    image.src = url
  })
}

調用:

loadImageAsync("圖片路徑").then((value) => {
  document.getElementById("d1").appendChild(value)
}).catch((err) => {
  console.log(err.message)
})
異步加載 js

實現方法:

let loadScript = function () {
  return function _loadScript(url, callBack) {
    return new Promise(function (resolve) {
      let script = document.createElement("script")
      script.type = "text/javascript"
      if (script.readyState) {
        // 兼容IE的script加載事件
        script.onreadystatechange = function () {
          // loaded : 下載完畢 complete: 數據準備完畢。這兩個狀態ie可能同時出現或者只出現一個
          if (script.readyState === "loaded" || script.readyState === "complete") {
            // 防止加載兩次
            script.onreadystatechange = null
            callBack()
            // 把函數傳遞下去,保證能順序加載js
            resolve(_loadScript)
          }
        }
      } else {
        script.onload = function () {
          callBack()
          resolve(_loadScript)
        }
      }
      script.src = url
      document.head.appendChild(script)
    })
  }
}()

調用:

loadScript("http://code.jquery.com/jquery-3.2.1.min.js ", () => {})
    .then(() => {
      $("#d1").on("click", () => {alert(1)})
    }).catch((err) => {
      console.log(err)
    })
request 請求的封裝
import axios from "./axios"
import qs from "qs"

const config = {
  time: +new Date() + "",
  timeout: 6000,
  headers: {
    "Content-Type": "application/x-www-form-urlencoded",
    time: new Date().getTime()
  }
}

function checkResponse (response, notice) {
  return new Promise((resolve, reject) => {
    let code = Number(response.code)
    if (code === 0 || code === 200 || code === 2000 || code === 1 || code === 2 || code === "0" || code === 109) {
      resolve(response)
    } else {
      if (notice) {
        // 提示信息
        console.log("response-notice", notice)
      }
      reject(response)
    }
  })
}

function fixURL (url, type) {
  let result = ""
  switch (type) {
    case "r":
      result += `/api/v2${url}`
      break
  }
  return result
}

/**
 * Requests a URL, returning a promise.
 *
 * @param  {object} [options]         The options we want to pass to axios
 * @param  {string} [options.url]     請求的url地址(必須)
 * @param  {string} [options.method]  請求方式, get or post,默認post
 * @param  {object} [options.data]    請求參數
 * @param  {number} [options.timeout] 請求超時時間
 * @param  {boolean} [options.notice] 請求失敗是否顯示提示,默認true
 * @return {object}                   promise對象
 */
function request (options = {}) {
  let {
    url,
    method,
    data,
    timeout,
    headers,
    type,
    notice
  } = options

  method = method || "post"
  data = data || {}
  type = type || "t"
  timeout = timeout || config.timeout
  headers = Object.assign({}, config.headers, headers)
  notice = notice === undefined ? true : notice

  let result = {}
  if (method === "get") {
    result = new Promise((resolve, reject) => {
      axios({
        method: "get",
        url: fixURL(url, type),
        params: data,
        timeout,
        headers
      })
        .then((res) => {
          checkResponse(res.data, notice).then((data) => {
            resolve(data)
          })
            .catch((data) => {
              reject(data)
            })
        })
        .catch((data) => {
          reject(data)
        })
    })
  } else if (method === "post") {
    result = new Promise((resolve, reject) => {
      axios({
        method: "post",
        url: fixURL(url, type),
        data: headers["Content-Type"] === "application/x-www-form-urlencoded" ? qs.stringify(data) : data,
        timeout,
        headers
      })
        .then((res) => {
          checkResponse(res.data, notice).then((data) => {
            resolve(data)
          })
            .catch((data) => {
              reject(data)
            })
        })
        .catch((data) => {
          reject(data)
        })
    })
  }
  return result
}

export default request
附 Promise 代碼實現
// 判斷變量否為function
const isFunction = variable => typeof variable === "function"
// 定義Promise的三種狀態常量
const PENDING = "PENDING"
const FULFILLED = "FULFILLED"
const REJECTED = "REJECTED"

class MyPromise {
  constructor (handle) {
    if (!isFunction(handle)) {
      throw new Error("MyPromise must accept a function as a parameter")
    }
    // 添加狀態
    this._status = PENDING
    // 添加狀態
    this._value = undefined
    // 添加成功回調函數隊列
    this._fulfilledQueues = []
    // 添加失敗回調函數隊列
    this._rejectedQueues = []
    // 執行handle
    try {
      handle(this._resolve.bind(this), this._reject.bind(this)) 
    } catch (err) {
      this._reject(err)
    }
  }
  // 添加resovle時執行的函數
  _resolve (val) {
    const run = () => {
      if (this._status !== PENDING) return
      // 依次執行成功隊列中的函數,并清空隊列
      const runFulfilled = (value) => {
        let cb;
        while (cb = this._fulfilledQueues.shift()) {
          cb(value)
        }
      }
      // 依次執行失敗隊列中的函數,并清空隊列
      const runRejected = (error) => {
        let cb;
        while (cb = this._rejectedQueues.shift()) {
          cb(error)
        }
      }
      /* 如果resolve的參數為Promise對象,則必須等待該Promise對象狀態改變后,
        當前Promsie的狀態才會改變,且狀態取決于參數Promsie對象的狀態
      */
      if (val instanceof MyPromise) {
        val.then(value => {
          this._value = value
          this._status = FULFILLED
          runFulfilled(value)
        }, err => {
          this._value = err
          this._status = REJECTED
          runRejected(err)
        })
      } else {
        this._value = val
        this._status = FULFILLED
        runFulfilled(val)
      }
    }
    // 為了支持同步的Promise,這里采用異步調用
    setTimeout(run, 0)
  }
  // 添加reject時執行的函數
  _reject (err) { 
    if (this._status !== PENDING) return
    // 依次執行失敗隊列中的函數,并清空隊列
    const run = () => {
      this._status = REJECTED
      this._value = err
      let cb;
      while (cb = this._rejectedQueues.shift()) {
        cb(err)
      }
    }
    // 為了支持同步的Promise,這里采用異步調用
    setTimeout(run, 0)
  }
  // 添加then方法
  then (onFulfilled, onRejected) {
    const { _value, _status } = this
    // 返回一個新的Promise對象
    return new MyPromise((onFulfilledNext, onRejectedNext) => {
      // 封裝一個成功時執行的函數
      let fulfilled = value => {
        try {
          if (!isFunction(onFulfilled)) {
            onFulfilledNext(value)
          } else {
            let res =  onFulfilled(value);
            if (res instanceof MyPromise) {
              // 如果當前回調函數返回MyPromise對象,必須等待其狀態改變后在執行下一個回調
              res.then(onFulfilledNext, onRejectedNext)
            } else {
              //否則會將返回結果直接作為參數,傳入下一個then的回調函數,并立即執行下一個then的回調函數
              onFulfilledNext(res)
            }
          }
        } catch (err) {
          // 如果函數執行出錯,新的Promise對象的狀態為失敗
          onRejectedNext(err)
        }
      }
      // 封裝一個失敗時執行的函數
      let rejected = error => {
        try {
          if (!isFunction(onRejected)) {
            onRejectedNext(error)
          } else {
              let res = onRejected(error);
              if (res instanceof MyPromise) {
                // 如果當前回調函數返回MyPromise對象,必須等待其狀態改變后在執行下一個回調
                res.then(onFulfilledNext, onRejectedNext)
              } else {
                //否則會將返回結果直接作為參數,傳入下一個then的回調函數,并立即執行下一個then的回調函數
                onFulfilledNext(res)
              }
          }
        } catch (err) {
          // 如果函數執行出錯,新的Promise對象的狀態為失敗
          onRejectedNext(err)
        }
      }
      switch (_status) {
        // 當狀態為pending時,將then方法回調函數加入執行隊列等待執行
        case PENDING:
          this._fulfilledQueues.push(fulfilled)
          this._rejectedQueues.push(rejected)
          break
        // 當狀態已經改變時,立即執行對應的回調函數
        case FULFILLED:
          fulfilled(_value)
          break
        case REJECTED:
          rejected(_value)
          break
      }
    })
  }
  // 添加catch方法
  catch (onRejected) {
    return this.then(undefined, onRejected)
  }
  // 添加靜態resolve方法
  static resolve (value) {
    // 如果參數是MyPromise實例,直接返回這個實例
    if (value instanceof MyPromise) return value
    return new MyPromise(resolve => resolve(value))
  }
  // 添加靜態reject方法
  static reject (value) {
    return new MyPromise((resolve ,reject) => reject(value))
  }
  // 添加靜態all方法
  static all (list) {
    return new MyPromise((resolve, reject) => {
      /**
       * 返回值的集合
       */
      let values = []
      let count = 0
      for (let [i, p] of list.entries()) {
        // 數組參數如果不是MyPromise實例,先調用MyPromise.resolve
        this.resolve(p).then(res => {
          values[i] = res
          count++
          // 所有狀態都變成fulfilled時返回的MyPromise狀態就變成fulfilled
          if (count === list.length) resolve(values)
        }, err => {
          // 有一個被rejected時返回的MyPromise狀態就變成rejected
          reject(err)
        })
      }
    })
  }
  // 添加靜態race方法
  static race (list) {
    return new MyPromise((resolve, reject) => {
      for (let p of list) {
        // 只要有一個實例率先改變狀態,新的MyPromise的狀態就跟著改變
        this.resolve(p).then(res => {
          resolve(res)
        }, err => {
          reject(err)
        })
      }
    })
  }
  finally (cb) {
    return this.then(
      value  => MyPromise.resolve(cb()).then(() => value),
      reason => MyPromise.resolve(cb()).then(() => { throw reason })
    );
  }
}

參考文章
Promise 官網
ECMAScript 6 入門
Promise 源碼詳解
Promise 實現原理(附源碼)
es6-promise-try npm
JavaScript Promise:簡介

文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。

轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/99301.html

相關文章

  • 淺談Javascript中Promise對象的實現

    摘要:我們可以進行適當的改進,把回調函數寫到外面即使是改寫成這樣,代碼還是不夠直觀,但是如果有了對象,代碼就可以寫得非常清晰,一目了然,請看這樣函數就不用寫在的回調中了目前的標準中還未支持對象,那么我們就自己動手,豐衣足食吧。 本文同步自我得博客:http://www.joeray61.com 很多做前端的朋友應該都聽說過Promise(或者Deferred)對象,今天我就講一下我對Prom...

    caiyongji 評論0 收藏0
  • 淺談Promise之參照Promise/A+規范實現Promise

    摘要:在需要多個操作的時候,會導致多個回調函數嵌套,導致代碼不夠直觀,就是常說的回調地獄,通常通過來解決本意是承諾,在程序中的意思就是承諾我過一段時間后會給你一個結果。 在需要多個操作的時候,會導致多個回調函數嵌套,導致代碼不夠直觀,就是常說的回調地獄,通常通過promise來解決Promise本意是承諾,在程序中的意思就是承諾我過一段時間后會給你一個結果。 什么時候會用到過一段時間?答案是...

    roundstones 評論0 收藏0
  • 淺談ES6原生Promise

    摘要:如果有錯誤,則到的第二個回調函數中,對錯誤進行處理。假設第一個的第一個回調沒有返回一個對象,那么第二個的調用者還是原來的對象,只不過其的值變成了第一個中第一個回調函數的返回值。 ES6標準出爐之前,一個幽靈,回調的幽靈,游蕩在JavaScript世界。 正所謂: 世界本沒有回調,寫的人多了,也就有了})})})})})。 Promise的興起,是因為異步方法調用中,往往會出現回調函數一...

    yedf 評論0 收藏0
  • 淺談JavaScript中的事件循環機制

    摘要:事件循環背景是一門單線程非阻塞的腳本語言,單線程意味著,代碼在執行的任何時候,都只有一個主線程來處理所有的任務。在意識到該問題之際,新特性中的可以讓成為一門多線程語言,但實際開發中使用存在著諸多限制。這個地方被稱為執行棧。 事件循環(Event Loop) 背景 JavaScript是一門單線程非阻塞的腳本語言,單線程意味著,JavaScript代碼在執行的任何時候,都只有一個主線程來...

    Pluser 評論0 收藏0
  • 淺談異步編程

    摘要:等到一段時間后,車到了,小紅打電話給小明車到了發布,小明在接到電話之后,要做一些準備訂閱時定義的回調函數。工作中的異步通過事件實例去做調控,簡單的代碼示例是一個事件實例,負責發布訂閱者的內部實現訂閱發布另一端程序干一些事情。 淺談異步編程 引子 頁面渲染與setTimeout(); 同步與異步------我的理解 任務在當次事件循環中阻塞后續任務進行的(指的是耗時較多,這個多少,暫時還...

    laoLiueizo 評論0 收藏0
  • 淺談promise和js執行機制(一)

    摘要:如果改變已經發生了,你再對對象添加回調函數,也會立即得到這個結果。其次,如果不設置回調函數,內部拋出的錯誤,不會反應到外部。作為一個入門級前端,今天是一個非常值得紀念的日子,因為這是我第一次在論壇上發表帖子,作為起步。雖然我覺得自己水平還是十分的有限,對一些細節的理解還不是很透徹,但是還是要邁出這一步,不管是給別的新手作為學習參考,還是自己以后回顧,總覺得需要把自己的成長記錄下來,希望自己以...

    haitiancoder 評論0 收藏0

發表評論

0條評論

李濤

|高級講師

TA的文章

閱讀更多
最新活動
閱讀需要支付1元查看
<