草庐IT

《Go 语言并发之道》读书笔记(六)

dk168 2023-03-28 原文

今天这篇笔记我们来学习一下context包
context包的一个应用场景是可以通过它控制goroutine的取消,超时等。
我们先来看一个取消的例子

context.WithCancel

func doSomething(ctx context.Context) {
	ctx, cancelctx := context.WithCancel(ctx)
	printCh := make(chan int)
	go doAnother(ctx, printCh)


	for i := 0; i < 3; i++ {
		printCh <- i
	}
	cancelctx()

	fmt.Println("do something finished")

}

func doAnother(ctx context.Context, printCh chan int) {
	for {
		select {
		case <-ctx.Done():
			if err := ctx.Err(); err != nil {
				fmt.Printf("do Another with error, %s \n", err)
			}
			fmt.Println("do Another finished")
			return
		case data := <-printCh:
			fmt.Printf("receive %d \n", data)
		}

	}

}

我们在doSomething方法中加了一个可以取消的Context, 然后定义了一个channel, 往channel里面放入3个数,另外启动一个goroutine doAnother 来接收它, 在完成放入数据后我们调用了取消方法, 通知doAnother 结束掉。 这样程序就达到一个goroutine通知另外一个goroutine的效果, 程序运行结果如下

receive 0 
receive 1 
receive 2
do Another with error, context canceled
do Another finished
do something finished

通过打印的输出我们可以看到doAnother是通过canneled来结束的。
如果我们再加一个goroutine,也能够通过context来取消。 这里比较简单不贴代码了。

context.WithTimeout

如果只是单纯的通知另外一个goroutine,直接通过close channel也可以做到了, Context还可以通过WithTimeout设定超时时间来限定程序运行多久,我们简单改造一下上面的代码


func doSomething(ctx context.Context) {
	ctx, cancelctx := context.WithTimeout(ctx, 1500*time.Millisecond)
	defer cancelctx()

	printCh := make(chan int)
	go doAnother(ctx, printCh)

outer:
	for i := 0; i < 3; i++ {
		select {
		case printCh <- i:
			time.Sleep(1 * time.Second)
		case <-ctx.Done():
			break outer
		}
	}
	cancelctx()

	fmt.Println("do something finished")

我们把doSomething改造了一下, 通过context.WithTimeout(ctx, 1500*time.Millisecond)将context 改成运行1.5秒就退出, doAnother 保持不变, 然后发送的时候,发送一个就sleep 1秒。 运行效果如下

receive 0 
receive 1 
do Another with error, context deadline exceeded 
do Another finished
do something finished

我们可以看到只发送了两个数,就退出了,退出的原因是exceeded. 这样就达到了控制goroutine运行时间的效果。
通过context.WithDeadline 也可以达到和WithTimeout一样的效果,只是一个是按时间点来停,一个是按时间段来停, 示例代码如下

deadLineTime := time.Now().Add(1500 * time.Millisecond)
ctx, cancelctx := context.WithDeadline(ctx, deadLineTime)

context.WithValue

context还有个用途是用来记录和传递value, 比如我们可以向别的goroutine传递UserID,RequestID等要跟踪的变量信息。 还是通过示例代码来说明


func main() {
	var ctx = context.Background()
	key := 1
	ctx = context.WithValue(ctx, key, "someValue")
	doSomething(ctx)
}

func doSomething(ctx context.Context) {
	fmt.Printf("Doing something! %s \n", ctx.Value(1))

}

输出结果很简单就是"Doing something! someValue" 这个someValue就是通过Context传递给doSomething方法里面的。 如果ctx.Value的key不存在,也不会报错,会返回nil.
上面key的写法,Visual Studio Code会提示”should not use built-in type int as key for value; define your own type to avoid collisions“
就是说这个key可能冲突,比如你的程序用String "userID", 别人也用String ”userID“, 你取的时候取到别人用的了,那样就给程序带来隐患, 我们需要自定义key, 如下代码示例

type ctxKey int

const (
	ctxUserKey ctxKey = iota
	ctxAuthToken
)

func main() {
	var ctx = context.Background()
	ctx = context.WithValue(ctx, ctxUserKey, "someValue")
	doSomething(ctx)
}

func doSomething(ctx context.Context) {
	fmt.Printf("Doing something! %s \n", ctx.Value(ctxUserKey))

}

我们定义了常量ctxUserKey, 它是ctxKey类型,ctxUserKey它的实际值是0, 在取值和赋值的时候我们同意用ctxUserKey, 这样就能很清楚明白的拿到它的value. 如果我们用ctx.Value(0)是拿不到值的。

最后

作者在书中说context包的包一直存在争议,为什么呢? 因为它可以放入任意类型,这样就让有些偷懒的程序员把它当垃圾桶, 程序运行需要的参数也用它来传递,这样它就被赋予了太多它不应该的功能。 那么我们需要遵守一定的规则来使用它,作者给出了建议
1, 数据应该通过进程或API边界, 这句话感觉是翻译问题,不是特别清楚,我感觉作者的意思是通过明确的参数来传递数据,而不是context
2,数据应该是不可变的。 意思就是只WithValue一次,不要去修改它
3,数据应该趋向简单类型, 保持简单很重要
4,数据应该是数据,而不是类型与方法, 也是保持简单
5,数据应该用于装饰操作,而不是驱动操作。意思就是你不要通过context里面的内容来决定你的代码逻辑。

作者最后说context提供的取消功能非常有用, 就是WithValue不要滥用。这一章感觉翻译的不好,读起来很晦涩,我还是看了另外一篇文章搞明白的。 贴出链接在此https://www.digitalocean.com/community/tutorials/how-to-use-contexts-in-go

有关《Go 语言并发之道》读书笔记(六)的更多相关文章

  1. ruby - 如何将脚本文件的末尾读取为数据文件(Perl 或任何其他语言) - 2

    我正在寻找执行以下操作的正确语法(在Perl、Shell或Ruby中):#variabletoaccessthedatalinesappendedasafileEND_OF_SCRIPT_MARKERrawdatastartshereanditcontinues. 最佳答案 Perl用__DATA__做这个:#!/usr/bin/perlusestrict;usewarnings;while(){print;}__DATA__Texttoprintgoeshere 关于ruby-如何将脚

  2. ruby - 寻找通过阅读代码确定编程语言的ruby gem? - 2

    几个月前,我读了一篇关于ruby​​gem的博客文章,它可以通过阅读代码本身来确定编程语言。对于我的生活,我不记得博客或gem的名称。谷歌搜索“ruby编程语言猜测”及其变体也无济于事。有人碰巧知道相关gem的名称吗? 最佳答案 是这个吗:http://github.com/chrislo/sourceclassifier/tree/master 关于ruby-寻找通过阅读代码确定编程语言的rubygem?,我们在StackOverflow上找到一个类似的问题:

  3. Unity 热更新技术 | (三) Lua语言基本介绍及下载安装 - 2

    ?博客主页:https://xiaoy.blog.csdn.net?本文由呆呆敲代码的小Y原创,首发于CSDN??学习专栏推荐:Unity系统学习专栏?游戏制作专栏推荐:游戏制作?Unity实战100例专栏推荐:Unity实战100例教程?欢迎点赞?收藏⭐留言?如有错误敬请指正!?未来很长,值得我们全力奔赴更美好的生活✨------------------❤️分割线❤️-------------------------

  4. 7个大一C语言必学的程序 / C语言经典代码大全 - 2

    嗨~大家好,这里是可莉!今天给大家带来的是7个C语言的经典基础代码~那一起往下看下去把【程序一】打印100到200之间的素数#includeintmain(){ inti; for(i=100;i 【程序二】输出乘法口诀表#includeintmain(){inti;for(i=1;i 【程序三】判断1000年---2000年之间的闰年#includeintmain(){intyear;for(year=1000;year 【程序四】给定两个整形变量的值,将两个值的内容进行交换。这里提供两种方法来进行交换,第一种为创建临时变量来进行交换,第二种是不创建临时变量而直接进行交换。1.创建临时变量来

  5. LC滤波器设计学习笔记(一)滤波电路入门 - 2

    目录前言滤波电路科普主要分类实际情况单位的概念常用评价参数函数型滤波器简单分析滤波电路构成低通滤波器RC低通滤波器RL低通滤波器高通滤波器RC高通滤波器RL高通滤波器部分摘自《LC滤波器设计与制作》,侵权删。前言最近需要学习放大电路和滤波电路,但是由于只在之前做音乐频谱分析仪的时候简单了解过一点点运放,所以也是相当从零开始学习了。滤波电路科普主要分类滤波器:主要是从不同频率的成分中提取出特定频率的信号。有源滤波器:由RC元件与运算放大器组成的滤波器。可滤除某一次或多次谐波,最普通易于采用的无源滤波器结构是将电感与电容串联,可对主要次谐波(3、5、7)构成低阻抗旁路。无源滤波器:无源滤波器,又称

  6. ruby-on-rails - 获取并发布相同匹配项的请求 - 2

    在我的路线文件中我有:match'graphs/(:id(/:action))'=>'graphs#(:action)'如果是GET请求(工作)或POST请求(不工作),我想匹配它我知道我可以使用以下方法在资源中声明POST请求:post'/'=>:show,:on=>:member但是我怎样才能为比赛做到这一点呢?谢谢。 最佳答案 如果你同时想要POST和GETmatch'graphs/(:id(/:action))'=>'graphs#(:action)',:via=>[:get,:post]编辑默认值可以设置如下match'g

  7. ruby - 如何保持我不常用的编程语言技能 - 2

    关闭。这个问题是off-topic.它目前不接受答案。想改进这个问题吗?Updatethequestion所以它是on-topic用于堆栈溢出。关闭11年前。Improvethisquestion我不经常使用ruby​​-通常它加起来相当于每两个月或更长时间编写一次脚本。我的大部分编程都是使用C++进行的,这与ruby​​有很大不同。由于我与ruby​​之间的差距如此之大,我总是忘记语言的基本方面(比如解析文本文件和其他简单的东西)。我想每天练习一些基本的东西,我想知道是否有一些我可以订阅的网站,并且会向我发送当天的Ruby问题或类似的东西。有人知道这样的站点/Internet服务吗?

  8. ruby-on-rails - 如果特定语言环境中缺少翻译,如何配置 i18n 以使用 en 语言环境? - 2

    如果特定语言环境中缺少翻译,如何配置i18n以使用en语言环境翻译?当前已插入翻译缺失消息。我正在使用RoR3.1。 最佳答案 找到相似的question这里是答案:#application.rb#railswillfallbacktoconfig.i18n.default_localetranslationconfig.i18n.fallbacks=true#railswillfallbacktoen,nomatterwhatissetasconfig.i18n.default_localeconfig.i18n.fallback

  9. ruby-on-rails - 如何通过 URL 更改语言环境? - 2

    在我的双语Rails4应用程序中,我有一个像这样的LocalesController:classLocalesController用户可以通过此表单更改其语言环境:deflocale_switcherform_tagurl_for(:controller=>'locales',:action=>'change_locale'),:method=>'get',:id=>'locale_switcher'doselect_tag'set_locale',options_for_select(LANGUAGES,I18n.locale.to_s)end这有效。但是,目前用户无法通过URL更改

  10. ruby - 一种语言如何被自身解释(如 Rubinius)? - 2

    我使用Ruby编程已经有一段时间了,现在只使用Ruby的标准MRI实现,但我一直对我经常听到的其他实现感到好奇。前几天我在读有关Rubinius的文章,这是一个用Ruby编写的Ruby解释器。我试着在不同的地方查找它,但我很难弄清楚这样的东西到底是如何工作的。我在编译器或语言编写方面从来没有太多经验,但我真的很想弄明白。一门语言究竟如何才能被自己解释?编译中是否有一个我不明白这有意义的基本步骤?有人可以像我是个白痴一样向我解释这个吗(因为无论如何这都不会太离谱) 最佳答案 它比你想象的要简单。Rubinius并非100%用Ruby编

随机推荐