golang的协程上下文的具体使用

更新时间：2022年04月11日 15:31:43 作者：zhijie

golang的context 主要用来在 goroutine 之间传递上下文信息，包括：取消信号、超时时间、截止时间、k-v 等，本文就详细的来介绍一下golang的协程上下文的具体使用，感兴趣的可以了解一下

go协程上下文context

golang的context 主要用来在 goroutine 之间传递上下文信息，包括：取消信号、超时时间、截止时间、k-v 等

context是golang1.17版本之后才出的特性

上下文解决的问题

协程间的通信

例如web应用中，每一个请求都由一个协程去处理。当然处理处理请求的这个协程，一般我们还会起一些其他的协程，用来处理其他的业务，比如操作数据库，生份验证、文件读写等。这些协程是独立的，我们在当前的协程中无法感知到其他的协程执行的情况怎么样了。实用通道channel可以实现通讯功能

context中context.WithValue()本质上也是通过channel来实现通讯

子协程的超时处理

同样例如web应用当中，我们主进程是一直常驻内存的。每一个请求都由一个协程去处理，在处理业务的过程中可能会起另外的协程去处理其他的业务，当子协程出现了异常或者阻塞了，无法向上一级的协程反馈信息，主协程接受不到反馈也会阻塞。上下文可以很好的解决这个问题，context可以实现子协程或子孙协程的超时退出或定时退出

上下文的几个方法和用法

context.WithCancel(context.Context)

WithCancel()方法传入一个上下文空实例，直接用context.Background()即可，返回一个上下文和一个取消函数。调用cancal()会向其他协程传递信号，收到信号后子协程就可以做关闭或其他处理

package main

import (
    "context"
    "fmt"
    "time"
)
func worker(ctx context.Context) {
    for {
        select {
        case <-ctx.Done():
            return
        default:
        }
        fmt.Println("worker...")
        time.Sleep(time.Second * 1)
    }
}
func main() {
    ctx, cancal := context.WithCancel(context.Background())
    go worker(ctx)
    time.Sleep(time.Second * 5)
    cancal()
    fmt.Println("over ...")

}

context.WithTimeout(context.Context，timeout)

定义一个会超时的上下文，实例化后倒计时就开始，到时间会自动调用cancel()函数通知子协程,也可以手动调用cancel()通知。如果子协程中还有子协程，继续使用这个上下文，当主协程发出取消信号时每一个使用了这个上下文的都会收到通知

package main

import (
    "context"
    "fmt"
    "time"
)

func worker(ctx context.Context) {
    for {
        select {
        case <-ctx.Done():
            return
        default:
        }
        fmt.Println("worker...")
        time.Sleep(time.Second * 1)
    }
}

func main() {
    ctx, cancal := context.WithTimeout(context.Background(), time.Second*2)
    go worker(ctx)
    time.Sleep(time.Second * 5)
    cancal()
    fmt.Println("over ...")

}

context.WithDeadline(context.Context，(绝对时间)timeout)

定义一个会超时的上下文，与Timeout不同在于，传入的时间是一个绝对时间。到了指定的时间会自动调用cancel()函数通知子协程,也可以手动调用cancel()通知。如果子协程中还有子协程，继续使用这个上下文，当主协程发出取消信号时每一个使用了这个上下文的都会收到通知

package main

import (
    "context"
    "fmt"
    "time"
)

func worker(ctx context.Context) {
    for {
        select {
        case <-ctx.Done():
            return
        default:
        }
        fmt.Println("worker...")
        time.Sleep(time.Second * 1)
    }
}

func main() {
    ctx, cancal := context.WithDeadline(context.Background(), time.Now().Add(3 * time.Second))
    go worker(ctx)
    time.Sleep(time.Second * 5)
    cancal()
    fmt.Println("over ...")

}

协程间的上下文通讯：context.WithValue()

先看一下这段代码

package main

import (
    "context"
    "fmt"
    "time"
)

type CTXKEY string

func worker(ctx context.Context) {
    // 在子协程中获取上下文信息
    num, ok := ctx.Value(CTXKEY("num")).(string)
    if !ok {
        fmt.Println("invalid trace code")
    }
    fmt.Println(num)
    for {
        select {
        case <-ctx.Done():
            return
        default:
        }
        fmt.Println("worker...")
        time.Sleep(time.Second * 1)
    }
}

func main() {
    ctx, cancal := context.WithDeadline(context.Background(), time.Now().Add(3*time.Second))
    // 利用上下文传一个 num = 1234567
    // 实例化一个上下文
    ctx = context.WithValue(ctx, CTXKEY("num"), "1234567")
    go worker(ctx)
    time.Sleep(time.Second * 5)
    cancal()
    fmt.Println("over ...")
}

通过上下文实现协程间的通信,如果项目大，为了避免变量的污染，原则上：上下文通信所用的key需要自定义一个类型

type traceCode string;context.WithValue(context.Context,key,value)

到此这篇关于golang的协程上下文的文章就介绍到这了,更多相关golang的协程上下文内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

一文搞懂Go语言中文件的读写与创建
这篇文章主要为大家详细介绍了Go语言中文件是如何实现读写与创建的，文中的示例代码讲解详细，对我们学习Go语言有一定帮助，需要的可以参考一下
2022-07-07
GO语言实现日志切割的示例详解
日志记录对程序排查问题比较关键，所以本文将选择Logrus和lumberjack两个库进行日志切割以及记录调用源，感兴趣的小伙伴可以了解一下
2023-07-07
golang channel多协程通信常用方法底层原理全面解析
channel 是 goroutine 与 goroutine 之间通信的重要桥梁,借助 channel,我们能很轻易的写出一个多协程通信程序,今天,我们就来看看这个 channel 的常用用法以及底层原理
2023-09-09
详解如何在golang镜像中设置指定时区
这篇文章主要为大家详细介绍了如何在golang镜像中设置指定时区，文中的示例代码讲解详细，具有一定的借鉴价值，感兴趣的可以了解一下
2023-04-04
深入了解Go语言中context的用法
这篇文章主要为大家详细介绍了Go语言中context用法的相关知识，文中的示例代码讲解详细，具有一定的学习价值，感兴趣的小伙伴可以跟随小编一起学习一下
2023-07-07
Go语言七篇入门教程三函数方法及接口
这篇文章主要为大家介绍了Go语言的函数方法及接口的示例详解，本文是Go语言七篇入门系列文章，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步
2021-11-11
Golang实现数据结构Stack(堆栈)的示例详解
在计算机科学中，stack（栈）是一种基本的数据结构，它是一种线性结构,具有后进先出（Last In First Out）的特点。本文将通过Golang实现堆栈，需要的可以参考一下
2023-04-04
golang版本升级的简单实现步骤
个人感觉Go在众多高级语言中,是在各方面都比较高效的,下面这篇文章主要给大家介绍了关于golang版本升级的简单实现步骤,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
2023-02-02
Go语言开发区块链只需180行代码(推荐)
这篇文章主要介绍了Go语言开发区块链只需180行代码,文章中将不会涉及工作量证明算法（PoW）以及权益证明算法（PoS）这类的共识算法。需要的朋友可以参考下
2018-05-05
goland中npm无法使用的问题及解决
这篇文章主要介绍了goland中npm无法使用的问题及解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-12-12