go 上下文:context.Context

来源:https://www.cnblogs.com/lianshuiwuyi/archive/2023/11/17/17837816.html
-Advertisement-
Play Games

Go語言中的上下文(Context)是一種用於在 Goroutines 之間傳遞取消信號、截止時間和其他請求範圍值的標準方式。context 包提供了 Context 類型和一些相關的函數,用於在併發程式中有效地傳遞上下文信息。 在Go語言中,上下文通常用於以下場景: 請求的傳遞:當一個請求從客戶端 ...


Go語言中的上下文(Context)是一種用於在 Goroutines 之間傳遞取消信號、截止時間和其他請求範圍值的標準方式。context 包提供了 Context 類型和一些相關的函數,用於在併發程式中有效地傳遞上下文信息。

在Go語言中,上下文通常用於以下場景:

  1. 請求的傳遞:當一個請求從客戶端發送到伺服器時,可以使用上下文來攜帶與該請求相關的數據。這些數據可以是用戶的身份信息、請求的元數據或其他與請求相關的信息。通過將上下文傳遞給處理該請求的goroutine,可以確保在整個處理過程中訪問這些數據。
  2. 取消操作:上下文可以用於取消正在進行的操作。當用戶或其他代碼發送取消信號時,可以將該信號傳遞給正在執行操作的goroutine。goroutine在接收到取消信號後,可以根據需要執行清理操作並退出。
  3. 截止時間:有時候需要在一段時間後終止正在進行的操作。通過將截止時間與上下文一起傳遞給goroutine,可以確保在超過截止時間後執行適當的清理操作並退出。
  4. 跨多個服務通信:當在分散式系統中使用Go語言時,上下文可以用於跨不同的服務之間傳遞請求數據、取消信號和截止時間。通過使用上下文,可以確保在整個系統中的各個服務之間保持一致的上下文和請求生命周期管理。

通過使用上下文,可以有效地在 Goroutines 之間傳遞取消信號、截止時間和請求範圍的值,從而更好地控制併發程式的行為。

1. context.Context 介面

Context 介面定義了在 Goroutines 之間傳遞的上下文的基本方法:

type Context interface {
    Deadline() (deadline time.Time, ok bool)
    Done() <-chan struct{}
    Err() error
    Value(key interface{}) interface{}
}
  • Deadline():返回上下文的截止時間。如果存在截止時間,oktrue,否則為 false
  • Done():返回一個通道,該通道關閉時表示上下文被取消或者超過了截止時間。
  • Err():返回上下文取消的原因。如果上下文沒有被取消,則返回 nil
  • Value(key):返回與給定 key 關聯的值。這允許在上下文中傳遞請求範圍的數據。

2. 創建上下文

在 Go 中,上下文可以通過 context.Background() 創建,它是一個無值的上下文,通常用作根上下文。根上下文不能被取消,也不能傳遞截止時間。

ctx := context.Background()

可以使用 context.WithCancelcontext.WithTimeoutcontext.WithDeadlinecontext.WithValue 等函數創建派生上下文,這些函數分別用於創建帶有取消、超時、截止時間和值的上下文。

// 創建一個帶有取消功能的上下文
ctx, cancel := context.WithCancel(context.Background())

// 創建一個帶有超時的上下文
ctx, cancel := context.WithTimeout(context.Background(), time.Second)

// 創建一個帶有截止時間的上下文
deadline := time.Now().Add(2 * time.Second)
ctx, cancel := context.WithDeadline(context.Background(), deadline)

// 創建一個帶有值的上下文
key := "key"
value := "value"
ctx := context.WithValue(context.Background(), key, value)

3. 傳遞上下文

在 Go 中,通過函數參數將上下文傳遞給調用的函數,從而使調用的函數能夠感知上下文的取消或超時。例如:

func myFunction(ctx context.Context) {
    // 在這裡使用 ctx 處理邏輯
    select {
    case <-ctx.Done():
        // 上下文被取消,執行清理工作
        fmt.Println("Context canceled")
        return
    default:
        // 繼續正常的邏輯
        fmt.Println("Doing some work")
    }
}

func main() {
    // 創建帶有取消功能的上下文
    ctx, cancel := context.WithCancel(context.Background())
    defer cancel()

    // 啟動 Goroutine,傳遞上下文
    go myFunction(ctx)

    // 主 Goroutine 執行一些工作
    time.Sleep(2 * time.Second)
}

4. 上下文的取消

調用 cancel() 函數會取消與上下文相關的 Goroutines。一旦上下文被取消,與之關聯的所有 Goroutines 都會收到取消信號。

ctx, cancel := context.WithCancel(context.Background())

// 啟動 Goroutine,傳遞上下文
go func(ctx context.Context) {
    select {
    case <-ctx.Done():
        // 上下文被取消,執行清理工作
        fmt.Println("Context canceled")
        return
    }
}(ctx)

// 取消上下文
cancel()

5. 上下文的超時和截止時間

使用 context.WithTimeoutcontext.WithDeadline 函數可以設置上下文的超時或截止時間。當超過指定的時間後,上下文會自動取消。

ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
defer cancel()

// 啟動 Goroutine,傳遞上下文
go func(ctx context.Context) {
    select {
    case <-ctx.Done():
        // 上下文超時,執行清理工作
        fmt.Println("Context timeout")
        return
    }
}(ctx)

// 主 Goroutine 執行一些工作
time.Sleep(3 * time.Second)

6. 上下文值

context.WithValue 函數可以用於在上下文中傳遞請求範圍的值。這些值可以通過 context.Value 方法在上下文中檢索。

ctx := context.WithValue(context.Background(), "user", "john_doe")

// 從上下文中獲取值
value := ctx.Value("user")
fmt.Println(value) // 輸出: john_doe

7. 上下文的鏈式調用

可以通過鏈式調用的方式,將多個上下文進行組合,形成一個父子關係的上下文鏈。

parentCtx := context.Background()
ctx1, cancel1 := context.WithTimeout(parentCtx, 2*time.Second)
defer cancel1()

ctx2, cancel2 := context.WithCancel(ctx1)
defer cancel2()

上述的 ctx2ctx1 的子上下文,當 ctx1 超時或被取消時,ctx2 也會相應地被取消。


孟斯特

聲明:本作品採用署名-非商業性使用-相同方式共用 4.0 國際 (CC BY-NC-SA 4.0)進行許可,使用時請註明出處。
Author: mengbin
blog: mengbin
Github: mengbin92
cnblogs: 戀水無意



您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 十一、指針和引用(一) 1、指針 1)思考 ​ 在電腦程式中,有一條鐵律那就是萬物皆內粗,而我們知道,記憶體就是一個個小格,存放著高電平或者低電平,也就是0或者1,我們要表達的一切都是通過這種二進位的方式放到記憶體中,當我們讀取、寫入,其實局勢在對應的記憶體空間執行讀或者寫操作 ​ 我們今天就研究研究, ...
  • 反面單例 代碼 import java.util.ArrayList; import java.util.List; /** * @since : 2023/11/17 **/ public class StupidSingleton { private static final StupidSin ...
  • C++ 指針學習筆記 引入 指針是什麼 指針是一個變數,其值為另一個變數的地址。 指針聲明的一般形式為: type *ptr_name; type 是指針的基類型,ptr_name 是指針的名稱,* 用來指定一個變數是指針 對於一個指針,需要明確四個方面的內容:指針的類型、指針所指向的類型、指針的值 ...
  • Hi i,m JinXiang ⭐ 前言 ⭐ 本篇文章主要介紹單元測試工具Junit使用以及部分理論知識 🍉歡迎點贊 👍 收藏 ⭐留言評論 📝私信必回喲😁 🍉博主收將持續更新學習記錄獲,友友們有任何問題可以在評論區留言 什麼是Junit單元測試? JUnit 是一個 Java 編程語言的單 ...
  • 聊聊Flink的必知必會(三) 聊聊Flink必知必會(四) 從源碼中,根據關鍵的代碼,梳理一下Flink中的時間與視窗實現邏輯。 WindowedStream 對數據流執行keyBy()操作後,再調用window()方法,就會返回WindowedStream,表示分區後又加窗的數據流。如果數據流沒 ...
  • 大家好,我是棧長。 今天給大家宣佈一個重大消息,又一國產項目宣佈加入 Apache,那就是 Alibaba 開源的分散式事務開源項目:Seata,Apache Seata 來了! 恭喜 Seata 成功加入 Apache 孵化器,走向全球。 說到 Seata,相信使用 Spring Cloud Al ...
  • 學習視頻:【孫哥說Spring5:從設計模式到基本應用到應用級底層分析,一次深入淺出的Spring全探索。學不會Spring?只因你未遇見孫哥】 第十章、對象的生命周期 1.什麼是對象的生命周期 指的是一個對象創建、存活、消亡的一個完整過程 2.為什麼要學習對象的生命周期 由Spring負責對象的創 ...
  • 一、概述 生成PDF文檔通常涉及使用模板引擎、PDF庫以及數據填充。常見以下幾種方法: iText:iText是一個強大的PDF庫,支持創建和操作PDF文檔。使用場景: 您可以使用iText來直接構建PDF文檔,也可以將其與模板引擎結合使用,通過數據填充來生成PDF。 Apache PDFBox: ...
一周排行
    -Advertisement-
    Play Games
  • C#.Net的BCL提供了豐富的類型,最基礎的是值類型、引用類型,而他們的共同(隱私)祖先是 System.Object(萬物之源),所以任何類型都可以轉換為Object。 ...
  • 最近有群友咨詢C#如何調用Python?小編嘗試Python.NET過程中遭遇的版本相容性和環境配置難題,小編決定尋找一個更為簡單、穩定且對初學者友好的解決方案。小編搜索一番,除了Python.NET之外,還有其他途徑能夠幫助我們輕鬆地在C#項目調用Python腳本,那就是通過命令行調用,使用 Sy ...
  • .NET中特性+反射 實現數據校驗 在.NET中,我們可以使用特性+反射來實現數據校驗。特性是一種用於為程式中的代碼添加元數據的機制。元數據是與程式中的代碼相關聯的數據,但不直接成為代碼的一部分。通過特性,我們可以為類、方法、屬性等添加額外的信息,這些信息可以在運行時通過反射獲取和使用。 對反射不太 ...
  • Biwen.Settings 是一個簡易的配置項管理模塊,主要的作用就是可以校驗並持久化配置項,比如將自己的配置存儲到資料庫中,JSON文件中等 使用上也是很簡單,只需要在服務中註入配置, 比如我們有一個GithubSetting的配置項,我們只需要定義好對象然後註入到Service中即可: [De ...
  • EDP是一套集組織架構,許可權框架【功能許可權,操作許可權,數據訪問許可權,WebApi許可權】,自動化日誌,動態Interface,WebApi管理等基礎功能於一體的,基於.net的企業應用開發框架。通過友好的編碼方式實現數據行、列許可權的管控。 ...
  • 前言 VB.NET,全名Visual Basic .NET,是Microsoft .NET框架的一部分,是一種面向對象的編程語言。它繼承了Visual Basic的易用性,同時增加了對面向對象編程的支持。VB.NET提供了大量的內置函數,使得開發者可以更容易地處理字元串、數學計算、文件和目錄訪問等任 ...
  • 自定義可移動點二維坐標軸控制項 目錄 路由參數 坐標軸控制項定義 Demo 路由參數 X_YResultCollection為當前X軸對應Y軸值存儲字典 public class ResultCollectionChangedEventArgs(RoutedEvent routedEvent, obje ...
  • 自定義分頁控制項 tip: 該控制項的樣式用的是materialDesign庫,需要下載Nuget包 Code Xaml <UserControl x:Class="TestTool.CustomControls.PagingControl" xmlns="http://schemas.microsof ...
  • 最近群里有個小伙伴把Dapper遷移SqlSugar幾個不能解決的問題進行一個彙總,我正好寫一篇文章來講解一下 一、sql where in傳參問題: SELECT * FROM users where id IN @ids 答: SqlSugar中應該是 var sql="SELECT * FRO ...
  • 安裝nuget包 Wesky.Net.OpenTools 1.0.8或以上版本。支持.net framework 4.6以上版本,以及所有.net core以及以上版本引用。 開發一個簡單的Winform界面,用來測試使用。如需該winform的demo,可以在公眾號【Dotnet Dancer】後 ...