最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

Go語言中的上下文取消操作詳解

 更新時間:2018年07月12日 09:22:13   作者:HULK一線技術雜談  
這篇文章主要給大家介紹了關于Go語言中上下文取消操作的相關資料,本文將解釋我們?nèi)绾卫蒙舷挛膸斓娜∠匦?,并通過一些模式和最佳實踐來使用取消,使你的程序更快、更健壯。需要的朋友可以參考借鑒,下面隨著小編來一起學習學習吧

前言

許多使用Go的人,都會用到它的上下文庫。大多數(shù)使用 context 進行下游操作,比如發(fā)出HTTP調(diào)用,或者從數(shù)據(jù)庫獲取數(shù)據(jù),或者在協(xié)程中執(zhí)行異步操作。最常見的用法是傳遞可由所有下游操作使用的公共數(shù)據(jù)。然而,一個不太為人所知,但非常有用的上下文特性是,它能夠在中途取消或停止一個操作。

本篇文章將解釋我們?nèi)绾卫蒙舷挛膸斓娜∠匦裕⑼ㄟ^一些模式和最佳實踐來使用取消,使你的程序更快、更健壯。

為什么需要取消?

簡而言之,我們需要取消,以防止我們的系統(tǒng)做不不需要的工作。

考慮HTTP服務器對數(shù)據(jù)庫的調(diào)用的常見情況,并將查詢的數(shù)據(jù)返回給客戶端:


時間圖,如果一切都很完美,就會是這樣的:

但是,如果客戶端取消了中間的請求,會發(fā)生什么呢?例如,如果客戶端關閉了他們的瀏覽器,這可能會發(fā)生。如果沒有取消,應用服務器和數(shù)據(jù)庫將繼續(xù)執(zhí)行它們的工作,即使工作的結果將被浪費:

理想情況下,如果我們知道進程(在本例中是HTTP請求)停止了,我們希望流程的所有下游組件停止工作:

1、上下文取消

現(xiàn)在我們知道了為什么需要取消,讓我們來看看如何實現(xiàn)它。因為“取消”的事件與交易或正在執(zhí)行的操作高度相關,所以它與上下文捆綁在一起是很自然的。

取消的有兩個方面,你可能想要實現(xiàn):

  • 監(jiān)聽取消事件
  • 提交取消事件

2、監(jiān)聽取消事件

上下文類型提供了 Done() 方法,每當上下文收到取消事件時,它都會返回接收空 struct{} 類型的通道。監(jiān)聽取消事件就像等待 <-ctx.done() 一樣簡單。

例如,讓我們考慮一個HTTP服務器,它需要兩秒鐘來處理一個事件。如果在此之前請求被取消,我們希望立即返回:

func main() {
  // Create an HTTP server that listens on port 8000
 http.ListenAndServe(":8000", http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
 ctx := r.Context()
 // This prints to STDOUT to show that processing has started
 fmt.Fprint(os.Stdout, "processing request\n")
 // We use `select` to execute a peice of code depending on which
 // channel receives a message first
 select {
   case <-time.After(2 * time.Second):
 // If we receive a message after 2 seconds
 // that means the request has been processed
 // We then write this as the response
 w.Write([]byte("request processed"))
   case <-ctx.Done():
 // If the request gets cancelled, log it
 // to STDERR
 fmt.Fprint(os.Stderr, "request cancelled\n")
 }
 }))
}

你可以通過運行服務器并在瀏覽器上打開localhost:8000來測試。如果你在2秒前關閉瀏覽器,你應該會看到在終端窗口上打印的“請求取消”。

3、提交取消事件

如果你有一個可以被取消的操作,你將不得不通過上下文發(fā)出取消事件。這可以通過 context 包中的 WithCancel 函數(shù)來完成,它返回一個上下文對象和一個函數(shù)。這個函數(shù)沒有參數(shù),也不返回任何東西,當你想要取消上下文時調(diào)用。

考慮兩個從屬操作的情況。在這里,“依賴”意味著如果一個失敗了,另一個就沒有意義了。在這種情況下,如果我們在早期就知道其中一個操作失敗了,我們想要取消所有的依賴操作。

func operation1(ctx context.Context) error {
 // Let's assume that this operation failed for some reason
 // We use time.Sleep to simulate a resource intensive operation
 time.Sleep(100 * time.Millisecond)
 return errors.New("failed")
}

func operation2(ctx context.Context) {
 // We use a similar pattern to the HTTP server
 // that we saw in the earlier example
 select {
  case <-time.After(500 * time.Millisecond):
 fmt.Println("done")
  case <-ctx.Done():
 fmt.Println("halted operation2")
 }
}

func main() {
 // Create a new context
 ctx := context.Background()

 // Create a new context, with its cancellation function
 // from the original context
 ctx, cancel := context.WithCancel(ctx)

 // Run two operations: one in a different go routine
 go func() {
 err := operation1(ctx)
 // If this operation returns an error
 // cancel all operations using this context
 if err != nil {
 cancel()
 }
 }()
 // Run operation2 with the same context we use for operation1
 operation2(ctx)
}

4、基于時間取消

任何需要在請求的最大持續(xù)時間內(nèi)維護SLA(服務水平協(xié)議)的應用程序都應該使用基于時間的取消。該API幾乎與前面的示例相同,并添加了一些內(nèi)容:

// The context will be cancelled after 3 seconds
// If it needs to be cancelled earlier, the `cancel` function can
// be used, like before

ctx, cancel := context.WithTimeout(ctx, 3*time.Second)

// The context will be cancelled on 2009-11-10 23:00:00
ctx, cancel := context.WithDeadline(ctx, time.Date(2009, time.November, 10, 23, 0, 0, 0, time.UTC))

例如,考慮對外部服務進行HTTP API調(diào)用。如果服務花費的時間太長,最好是盡早失敗并取消請求:

func main() {
 // Create a new context
 // With a deadline of 100 milliseconds
 ctx := context.Background()
 ctx, _ = context.WithTimeout(ctx, 100*time.Millisecond)
 // Make a request, that will call the google homepage
 req, _ := http.NewRequest(http.MethodGet, "http://google.com", nil)
 // Associate the cancellable context we just created to the request
 req = req.WithContext(ctx)

 // Create a new HTTP client and execute the request
 client := &http.Client{}
 res, err := client.Do(req)

 // If the request failed, log to STDOUT
 if err != nil {
 fmt.Println("Request failed:", err)
 return
 }

 // Print the statuscode if the request succeeds
 fmt.Println("Response received, status code:", res.StatusCode)
}

根據(jù)谷歌主頁對你的請求的響應速度,你將收到:

Response received, status code: 200

或者

Request failed: Get http://google.com: context deadline exceeded

你可以使用超時來實現(xiàn)上述兩個結果。

陷阱和警告

盡管Go的上下文取消是一個通用的工具,但是在繼續(xù)之前,有一些事情是你應該記住的。其中最重要的一點是, 上下文只能被取消一次 。

如果你想在同一個操作中提出多個錯誤,那么使用上下文取消可能不是最好的選擇。使用取消的最慣用的方法是,當你真正想要取消某些東西時,而不僅僅是通知下游進程,錯誤已經(jīng)發(fā)生了。

你需要記住的另一件事是,相同的上下文實例應該傳遞給所有你可能想要取消的功能和例程。用 WithTimeout 或 WithCancel 來包裝已經(jīng)可取消的上下文將會導致多種可能性,你的上下文可以被取消,并且應該避免。

總結

以上就是這篇文章的全部內(nèi)容了,希望本文的內(nèi)容對大家的學習或者工作具有一定的參考學習價值,如果有疑問大家可以留言交流,謝謝大家對腳本之家的支持。

相關文章

  • Go 語言json.Unmarshal 遇到的小問題(推薦)

    Go 語言json.Unmarshal 遇到的小問題(推薦)

    這篇文章主要介紹了 Go 語言json.Unmarshal 遇到的小問題,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2020-07-07
  • Go語言os包用法詳解

    Go語言os包用法詳解

    本文主要介紹了Go語言os包用法詳解,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧
    2023-04-04
  • Golang切片Slice功能操作詳情

    Golang切片Slice功能操作詳情

    這篇文章主要介紹了Golang切片功能操作詳情,切片是一個擁有相同類型元素的可變長度的序列。它是基于數(shù)組類型做的一層封,切片是一個引用類型,它的內(nèi)部結構包含地址、長度和容量
    2022-09-09
  • Go?文件讀取和寫入操作全面講解

    Go?文件讀取和寫入操作全面講解

    這篇文章主要為大家介紹了Go文件的讀取和寫入操作示例的全面詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-11-11
  • 深入了解Golang?哈希算法之MD5、SHA-1和SHA-256

    深入了解Golang?哈希算法之MD5、SHA-1和SHA-256

    哈希算法是計算機科學領域中一種重要的技術,它將任意長度的輸入數(shù)據(jù)映射為固定長度的哈希值,在本篇文章中,我們將深入探討Golang中的哈希算法,從多個方面介紹其詳細內(nèi)容,希望通過本文的閱讀你將對?Golang哈希算法有更全面的理解
    2023-05-05
  • Golang學習之內(nèi)存逃逸分析

    Golang學習之內(nèi)存逃逸分析

    內(nèi)存逃逸分析是go的編譯器在編譯期間,根據(jù)變量的類型和作用域,確定變量是堆上還是棧上。本文將帶大家分析一下Golang中的內(nèi)存逃逸,需要的可以了解一下
    2023-01-01
  • 淺析Go語言中的同步與異步處理

    淺析Go語言中的同步與異步處理

    在開發(fā)過程中,當需要同時處理多個操作時,開發(fā)者經(jīng)常面臨同步和異步兩種處理方式的選擇,下面小編就來和大家詳細介紹一下Go語言中的同步與異步處理吧
    2023-11-11
  • golang flag包的使用教程

    golang flag包的使用教程

    golang 的 flag 包是用于處理命令行參數(shù)的工具包,我們可以基于這個包來開發(fā)自定義的命令行工具,下面小編就來為大家介紹一下flag包的具體使用吧
    2023-09-09
  • GO實現(xiàn)跳躍表的示例詳解

    GO實現(xiàn)跳躍表的示例詳解

    跳表全稱叫做跳躍表,簡稱跳表,是一個隨機化的數(shù)據(jù)結構,實質就是一種可以進行二分查找的有序鏈表。本文將利用GO語言編寫一個跳表,需要的可以參考一下
    2022-12-12
  • Golang中使用errors返回調(diào)用堆棧信息

    Golang中使用errors返回調(diào)用堆棧信息

    這篇文章給大家介紹了Golang中如何使用errors返回調(diào)用堆棧信息,文章通過代碼示例給大家介紹的非常詳細,對大家的學習或工作有一定的幫助,需要的朋友可以參考下
    2023-12-12

最新評論

天镇县| 孝义市| 怀仁县| 贵德县| 揭阳市| 昌都县| 古浪县| 洪洞县| 蒙城县| 兴城市| 湖北省| 白银市| 余庆县| 贺兰县| 额济纳旗| 平顺县| 白朗县| 富宁县| 泽普县| 克拉玛依市| 太仓市| 西吉县| 启东市| 墨脱县| 县级市| 中卫市| 马山县| 苏尼特右旗| 南岸区| 固阳县| 龙胜| 湟源县| 金堂县| 嘉定区| 本溪市| 商城县| 南通市| 汉川市| 阳原县| 六盘水市| 长顺县|