Go学习笔记—标准库Context

标准库Context

​ 由于goroutine没有父子关系,多个goroutine都是被平行的调度,所以在拉起多个goroutine后,程序的执行模型并没有维护树状结构的goroutine树,所以无法靠语法层面,通知树中所有goroutine退出。context库就是为了解决这个问题而被引入,目的:

(1) 退出通知机制:通知可以传递给整个goroutine调用树上的每一个goroutine

(2) 传递数据:数据可以传递给goroutine调用树上的每一个goroutine

1. context—基础数据结构

——构造取消树根节点对象的两个函数

func Background() Context构造根节点,用作WithConcel的实参
func Todo() Context

——构建不同功能的Context对象

​ 这些方法都有一个参数parent,即在goroutine调用链中,每层都对Context实例包装自己所需的功能,并传递到下一层。

func WithCancel(parent Context) (ctx Context, cancel CancelFunc)带有退出通知的Context对象
func WithDeadline(parent Context, deadline time.Time) (Context, CancelFunc)带有超时通知的Context对象
func WithTimeout(parent Context, timeout time.Duration) (Context, CancelFunc)带有超时通知的Context对象
func WithValue(parent Context, key, value interface{}) Context能够传递数据的Context对象
2. context—用例

ctxa.children——>ctxb、ctxb.children——>ctxc

  • ctxa 创建时:&cancelCtx{Context: new(emptyCtx)}
  • ctxb 创建时: &timerCtx{cancelCtx: ctxa deadline:tm} 同时出发ctxa,在children中加入ctxb
  • ctxc 创建时:&cancelCtx{Context: mc} 同时通过mc.Context找到ctxb,通过ctxb.cancelCtx找到ctxa,在ctxa的children中加入ctxc
type selfcontext struct {context.Context
}func work(ctx context.Context, name string) { //一个子任务,参数包含上下文信息与子任务名for {select {case <-ctx.Done(): //从上下文接收到结束信息fmt.Printf("%s get msg to cancel\n", name)returndefault:fmt.Printf("%s is running\n", name)time.Sleep(1 * time.Second)}}
}func workWithValue(ctx context.Context, name string) { //一个子任务,参数包含带值的上下文信息与子任务名for {select {case <-ctx.Done(): //从上下文接收到结束信息fmt.Printf("%s get msg to cancel\n", name)returndefault:value := ctx.Value("key").(string) //获取上下文中存储的key值fmt.Printf("%s is running and value is %s\n", name, value)time.Sleep(1 * time.Second)}}
}func ContextTest() {//使用background构建一个WithCancel类型的上下文ctxa, cancel := context.WithCancel(context.Background())go work(ctxa, "work1") //在此上下文,开启一个goroutine//使用ctxa构建一个WithDeadline类型的上下文tm := time.Now().Add(3 * time.Second)ctxb, _ := context.WithDeadline(ctxa, tm)go work(ctxb, "work2") //在此上下文,开启一个goroutine//使用ctxb构建一个WithValue类型的上下文mc := selfcontext{ctxb}ctxc := context.WithValue(mc, "key", "i am work3")go workWithValue(ctxc, "work3") //在此上下文,开启一个goroutinetime.Sleep(10 * time.Second) //经过10s,由于ctxc,ctxb都包含Deadline上下文,所以都已经超时停止//显示调用wordk1的cancal()方法,结束work1cancel()
}

总结流程如下:

  1. 创建一个Context根对象 (通过Background或TODO创建)
  2. 包装上一步的Context对象,并加入特有功能 (通过WithCancel,WithTimeout,WithDeadline,WithValue创建)
  3. 将上一步创建的对象作为实参传递给后续启动的并发函数(一般作为其第一个参数),每个并发函数可以继续使用包装函数对传进来的Context对象进行包装,添加自己所需要的功能。
  4. 顶端的goroutine在超时后调用cancel退出通知函数,通知后面的所有goroutine释放资源。
  5. 后面的goroutine通过select监听Context.Done()返回的chan,及时相应前端goroutine的退出通知,释放资源。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/263567.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

宝剑锋从磨砺出——使用在线评测平台磨砺C#使用能力

学数学的时候&#xff0c;我们通常会通过大量的练习题来巩固所学知识&#xff1b;其实学习程序设计设计语言也不例外。那么如何通过练习去磨砺自己的C#使用能力呢&#xff1f;一个方法是参与到实际的软件项目开发中&#xff0c;而另一个更加直接的方法则是“做题”。 去哪里找练…

java多线程学习-java.util.concurrent详解(一) Latch/Barrier

2019独角兽企业重金招聘Python工程师标准>>> Java1.5提供了一个非常高效实用的多线程包&#xff1a;java.util.concurrent, 提供了大量高级工具&#xff0c;可以帮助开发者编写高效、易维护、结构清晰的Java多线程程序。从这篇blog起&#xff0c;我将跟大家一起共同…

55种网页常用小技巧(转载)

55种网页常用小技巧乖的无聊 发表于 2005-4-18 13:18:09  1. οncοntextmenu"window.event.returnValuefalse" 将彻底屏蔽鼠标右键<table border οncοntextmenureturn(false)><td>no</table> 可用于Table2. <body onselectstart"retu…

Go学习笔记—锁(sync包)

并发安全和锁 1. sync.Mutex—实现互斥锁 var lock sync.Mutex var x int func add() { //这样&#xff0c;在多个goroutine同时访问x时&#xff0c;才不会造成x错误for i : 0; i < 5000; i {lock.Lock() // 加锁x x 1lock.Unlock() // 解锁} }2. sync.RWMutex—实现读写…

switch…case语句注意事项

1、 case 的值必须是常量表达式&#xff0c;不允许使用变量。2、如果一个 case 子句为空&#xff0c;就可以从这个 case 跳到下一个 case 上&#xff0c;这样就可以用相同的方式处理两个或多个 case 子句了(不需要 goto 语句)。3、在C#中&#xff0c;可以把字符串用作测试变量。…

Java Websocket实例

2019独角兽企业重金招聘Python工程师标准>>> 介绍 现很多网站为了实现即时通讯&#xff0c;所用的技术都是轮询(polling)。轮询是在特定的的时间间隔&#xff08;如每1秒&#xff09;&#xff0c;由浏览器对服务器发出HTTP request&#xff0c;然后由服务器返回最新…

LeetCode 287. 寻找重复数

给定一个包含 n 1 个整数的数组 nums&#xff0c;其数字都在 1 到 n 之间&#xff08;包括 1 和 n&#xff09;&#xff0c;可知至少存在一个重复的整数。假设只有一个重复的整数&#xff0c;找出这个重复的数。 示例 1: 输入: [1,3,4,2,2]输出: 2示例 2: 输入: [3,1,3,4,2]输…

Go学习笔记—并发高级

Go并发机制 ​ 协程&#xff1a;一个线程可以对应多个协程&#xff0c;协程串行运行在用户空间。协程运行在线程之上&#xff0c;当一个协程执行完成后&#xff0c;可以选择主动让出&#xff0c;让另一个协程运行在当前线程之上。协程并没有增加线程数量&#xff0c;只是在线程…

设计模式C++学习笔记之十三(Decorator装饰模式)

装饰模式&#xff0c;动态地给一个对象添加一些额外的职责。就增加功能来说&#xff0c;Decorator模式相比生成子类更为灵活。 13.1.解释 main()&#xff0c;老爸 ISchoolReport&#xff0c;成绩单接口 CFourthGradeSchoolReport&#xff0c;四年级成绩单 ReportDecorator&…

Android应用开发相关下载资源(2014/12/14更新)

官方终于发布了Android Studio正式版&#xff0c;Android Studio将会成为推荐使用的主要Android开发工具. (1)Android SDK (Android SDK主安装包&#xff0c;包含SDK Manager、AVD Manager、工具包tools&#xff0c;释放后的根文件夹为android-sdk-windows): revision 23.0.2ht…

分层在深一步学习

前几天自己写了写DAL层,还有Model!理解到在DAL中主要是写的数据操作,而这些操作又是基于DbHelper这个基类!而数据库的访问则写在了这个基类中,目前还没研究BLL层,不过知道其中写的是算法!在Model中写的对象的属性,还有数据的规范(据说是,呵呵).自己对分层开发很感兴趣!呵呵,加油…

程序员编程艺术:第二章、字符串是否包含问题

程序员编程艺术&#xff1a;第二章、字符串是否包含及相关问题扩展 作者&#xff1a;July&#xff0c;yansha。时间&#xff1a;二零一一年四月二十三日。致谢&#xff1a;老梦&#xff0c;nossiac&#xff0c;Hession&#xff0c;Oliver&#xff0c;luuillu&#xff0c;雨翔&a…

LeetCode—207. 课程表

207. 课程表 题目描述&#xff1a;你这个学期必须选修 numCourses 门课程&#xff0c;记为 0 到 numCourses - 1 。 在选修某些课程之前需要一些先修课程。 先修课程按数组 prerequisites 给出&#xff0c;其中 prerequisites[i] [ai, bi] &#xff0c;表示如果要学习课程 ai…

详解为何在嵌套ESXi环境下要求开启Promiscuous Mode

原文链接&#xff1a;http://bbs.vmanager.cn/forum.php?modviewthread&tid8688&fromuid35445在嵌套环境中&#xff0c;有时候网路不通&#xff0c;此时&#xff0c;调整Promiscuous Mode选项为Accept之后&#xff0c;网路就可以通了。之前只是知道这个选项可以保证嵌…

Rapidmind计算库性能测试

rapidmind.net提供了免费的计算库下载&#xff0c;目的是使用C metaprogramming将计算与硬件平台隔离开来&#xff0c;它提供一套运行库做底层的优化工作。为了测试其真正的性能&#xff0c;以便于在未来的渲染器中使用&#xff0c;我做了一个简单的性能测试程序&#xff0c;将…

VMware 怎么进入BIOS

2019独角兽企业重金招聘Python工程师标准>>> 虚拟机(Vmware)引导Linux虚拟机时&#xff0c;需要设置成光盘启动来引导系统&#xff0c;但是vmware默认是硬盘启动&#xff0c;所以会启动不了或者别的问题存在。所以要进bios里面设置成开机的启动顺序&#xff0c;要将…

LeetCode—208. 实现 Trie (前缀树)

208. 实现 Trie (前缀树) 题目描述&#xff1a;Trie&#xff08;发音类似 “try”&#xff09;或者说 前缀树 是一种树形数据结构&#xff0c;用于高效地存储和检索字符串数据集中的键。这一数据结构有相当多的应用情景&#xff0c;例如自动补完和拼写检查。 请你实现 Trie 类…

SQL入侵恢复XP_CMDSHLL与开3389

一,用SQL连接器恢复XP_CMDSHLLE的命令 &#xff08;1&#xff09;sp_addextendedproc xp_cmdshell,dllnamexplog70.dll &#xff08;2&#xff09;首先在SqlExec Sunx Version的Format选项里填上%s&#xff0c;在CMD选项里输入 sp_addextendedproc xp_cmdshell,xpsql70.dll 去除…

java中long类型转换为int类型

由int类型转换为long类型是向上转换&#xff0c;可以直接进行隐式转换&#xff0c;但由long类型转换为int类型是向下转换&#xff0c;可能会出现数据溢出情况&#xff1a; 主要以下几种转换方法&#xff0c;供参考&#xff1a;一、强制类型转换 [java] long ll 300000; in…

中国最好的电子商务平台,75商务网成功上线

中国B2B电子商务网站多年处于停滞不前&#xff0c;行业垄断现象&#xff0c;而且非常专注于B2B方向发展&#xff0c;没有其他业务范围可以拓展。http://www.755563.com/ “ 75商务网 ”看到其中亮点&#xff0c;在原有B2B基础上增加新型模式&#xff0c;变成B2B2C形式&#xff…