客服电话
APP下载
迪恩网络APP
随时随地掌握行业动态
官方微信
扫描二维码
关注迪恩网络微信公众号
|
channel取数据时未被赋值将被阻塞，可以使用这一机制来完成事件的监听 wg := new(sync.WaitGroup)
wg.Add(2)
event := make(chan bool)
//函数
go func() {
defer wg.Done()
for i := 0; i < 5; i++ {
fmt.Println("触发事件前", i)
}
event <- true //触发事件
}()
go func() {
<-event
defer wg.Done()
for i := 0; i < 5; i++ {
fmt.Println("触发事件后", i)
}
}()
wg.Wait()
输出： 触发事件前 0
在使用Channel时要注意 如果chan的容量已满，将会发生死锁 如：
data:=make(chan int ,3) exit:=make(chan bool) data<-1 data<-2 data<-3 data<-4//运行到这里将被阻塞，因为chan容量已满
len返回chan中未被读取的元素数量，cap返回缓冲区大小，close关闭当前chan
判断chan是否关闭 for{
if d,ok:=<-data;ok}{
fmt.Println(d)
}else{
break
}
}
单向chan：只负责接收，或者只负责发送 相当于分离了chan的发送和接收，将其变为两个便于控制的变量 c := make(chan int, 3) var send chan<- int = c // send-only var recv <-chan int = c // receive-only send <- 1 <-recv
|
请发表评论