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的协程上下文内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要为大家介绍了gRPC的发布订阅模式及REST接口和超时控制，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-06-06
这篇文章主要介绍了Golang多线程刷票的相关资料,这里实现刷票的功能，对于投票，刷票的很方便，并附实现代码，需要的朋友可以参考下2017-07-07
在今天的软件开发中,使用Linux作为操作系统的比例越来越高,而Golang语言则因为其高效、简洁和并发性能等特点,也被越来越多的开发者所青睐,这篇文章主要给大家介绍了关于Go项目在linux服务器的部署详细步骤,需要的朋友可以参考下2023-09-09
这篇文章主要为大家详细介绍了如何利用Go语言实现Raft日志同步，文中的示例代码讲解详细，对我们深入了解Go语言有一定的帮助，需要的可以参考一下2023-05-05
go语言题解LeetCode453最小操作次数使数组元素相等
这篇文章主要为大家介绍了go语言题解LeetCode453最小操作次数使数组元素相等示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-12-12
反射和元编程是一些高级编程概念，它们使开发者能够在运行时检查、修改并控制程序的行为，了解反射和元编程的工作方式可以帮助我们更好地理解Go，以及如何在需要的时候高效地使用它们，文章中介绍的非常详细，感兴趣的同学可以参考下2023-05-05
DFA算法是确定性有限自动机,其特征是,有一个有限状态集合和一些从一个状态通向另一个状态的边,每条边上标记有一个符号,通俗的讲DFA算法就是把你要匹配的做成一颗字典树,然后对你输入的内容进行匹配的过程,本文将利用DFA算法实现敏感词过滤,需要的可以参考一下2023-10-10
这篇文章主要介绍了go之如何设置GOROOT和GOPATH问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-05-05
cobra既是一个用于创建强大现代CLI应用程序的库，也是一个生成应用程序和命令文件的程序。cobra被用在很多go语言的项目中，比如 Kubernetes、Docker、Istio、ETCD、Hugo、Github CLI等等2022-12-12
这篇文章主要介绍了GoLang切片相关的七个问题，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习吧2022-10-10
最新评论