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

来源：恒创科技编辑：恒创科技编辑部

2024-01-31 22:26:59

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

定义

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

ch2:=make(chanint)
ch3:=make(chanint,10)

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

场景

来看看这段代码：

packagemainimport(
"sync"
"fmt")funcmain(){
wg:=sync.WaitGroup{}

ch2:=make(chanint)

wg.Add(1)

fori:=0;i<10;i++{
ch2<-i
}

gofunc1(ch2,&wg)

wg.Wait()

close(ch2)
fmt.Println("Closechannel:",ch2)
}funcfunc1(chchanint,wg*sync.WaitGroup){
FOR:
for{
select{
casei,ok:=<-ch:
if!ok{
fmt.Println("1chanclosed,returning")
breakFOR
}else{
fmt.Println("1Gotnumber:",i)
ifi==9{
breakFOR
}
}
default:
fmt.Println("1Gotnothing")
}
}
wg.Done()
}

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

fatalerror:allgoroutinesareasleep-deadlock!

goroutine1[chansend]:
main.main()
/Users/bruce/Code/go/src/GoCommonServices/sync-demo/demo.go:19+0xb9exitstatus2Processfinishedwithexitcode1

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

ch2:=make(chanint)

fori:=0;i<10;i++{
ch2<-i
}

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

gofunc1(ch2,&wg)

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

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

ch2:=make(chanint，10)

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

gofunc1(ch2,&wg)

ch2:=make(chanint)

fori:=0;i<10;i++{
ch2<-i
}

归根结底，还是因为channel的特性：

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

go是什么

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

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

本文地址：https://www.henghost.com/jishu/20556/