Go无缓冲通道的陷阱是什么

91次阅读
没有评论

共计 1621 个字符,预计需要花费 5 分钟才能阅读完成。

本篇文章为大家展示了 Go 无缓冲通道的陷阱是什么,内容简明扼要并且容易理解,绝对能使你眼前一亮,通过这篇文章的详细介绍希望你能有所收获。

定义

Channel 是 go 的特色之一,甚至说是最大的特色也不为过,使用起来也非常简单。
首先定义一个 int 类型的 channel:

ch2 := make(chan int) 
ch3 := make(chan int, 10)

我们这里主要关注无缓冲通道。

场景

来看看这段代码:

package mainimport (
  sync 
  fmt )func main() { wg := sync.WaitGroup{}
 ch2 := make(chan int)
 wg.Add(1)
 for i := 0; i   10; i++ {
 ch2  - i
 }
 go func1(ch2,  wg) 
 wg.Wait()
 close(ch2)
 fmt.Println(Close channel:  , ch2)
}func func1(ch chan int, wg *sync.WaitGroup) {
 FOR:
 for {
 select {
 case i, ok :=  - ch:
 if !ok { fmt.Println( 1 chan closed, returning)
 break FOR
 } else { fmt.Println( 1 Got number:  , i)
 if i == 9 {
 break FOR
 }
 }
 default:
 fmt.Println(1 Got nothing)
 }
 }
 wg.Done()}

乍眼一看似乎没毛病,但是当运行程序的时候:

fatal error: all goroutines are asleep - deadlock!
goroutine 1 [chan send]:
main.main()
 /Users/bruce/Code/go/src/GoCommonServices/sync-demo/demo.go:19 +0xb9exit status 2Process finished with exit code 1

为什么呢?仔细看了看上面的程序,在定义了无缓冲通道 ch2 之后,立马向其中写入数据:

 ch2 := make(chan int)
 for i := 0; i   10; i++ {
 ch2  - i
 }

但此时并没有消费者,而无缓冲通道在写入一个数据之后,会等待消费者消费,程序阻塞,但启动消费者的代码:

 go func1(ch2,  wg)

恰好在 for 循环之后,所以这个 goroutine 永远没有启动的机会,这就是报错信息提示的,deadlock 了,要修复这个有两种方法:

1 ch2 定义为缓冲通道,足够容纳 for 中的数据,就不会阻塞

 ch2 := make(chan int, 10)

2 先启动消费者,再向通道中写数据

 go func1(ch2,  wg) 
 ch2 := make(chan int)
 for i := 0; i   10; i++ {
 ch2  - i
 }

归根结底,还是因为 channel 的特性:

无缓冲的 channel,不管是入还是出,都会阻塞,所以在同一个 goroutine 中,不能同时对同一个无缓冲 channel 进行入和出操作;带缓冲的 channel,在队列满之前,不会阻塞;队列满之后,依然会阻塞。go 是什么

golang 是一种编译语言,可以将代码编译为机器代码,编译后的二进制文件可以直接部署到目标机器而无需额外的依赖,所以 golang 的性能优于其他的解释性语言,且可以在 golang 中使用 goroutine 来实现并发性,它提供了一个非常优雅的 goroutine 调度程序系统,可以很容易地生成数百万个 goroutine。

上述内容就是 Go 无缓冲通道的陷阱是什么,你们学到知识或技能了吗?如果还想学到更多技能或者丰富自己的知识储备,欢迎关注丸趣 TV 行业资讯频道。

正文完
 
丸趣
版权声明:本站原创文章,由 丸趣 2023-08-03发表,共计1621字。
转载说明:除特殊说明外本站除技术相关以外文章皆由网络搜集发布,转载请注明出处。
评论(没有评论)