40.蛤蟆笔记go语言——并发
goroutine是Go并发能力的核心要素。
goroutine有简单的模型:它是与其他goroutine并行执行的,有着相同地址空间的函数。
goroutine是一个普通的函数,只是需要使用保留字go作为开头。
虽然goroutine是并发执行的,但是它们并不是并行运行的。如果不告诉Go额外的东西,同一时刻只会有一个goroutine执行。利用runtime.GOMAXPROCS(n)可以设置goroutine并行执行的数量。如果不希望修改任何源代码,同样可以通过设置环境变量 GOMAXPROCS 为目标值。
更多关于channel
当在Go中用ch :=make(chan bool)创建chennel时,bool型的无缓冲channel会被创建。这对于程序来说意味着什么呢?首先,如果读取(value := <-ch)它将会被阻塞,直到有数据接收。其次,任何发送(ch<-5)将会被阻塞,直到数据被读出。无缓冲channel是在多个goroutine之间同步很棒的工具。不过Go也允许指定channel的缓冲大小,很简单,就是channel可以存储多少元素。 ch := make(chan bool, 4),创建了可以存储 4 个元素的 bool 型 channel。在这个channel中,前4个元素可以无阻塞的写入。当写入第5 元素时,代码将会阻塞,直到其他goroutine从channel中读取一些元素,腾出空间。
有疑问加站长微信联系(非本文作者)