<span style="font-family: Arial, Helvetica, sans-serif; background-color: rgb(255, 255, 255);">go语言的channel是非常重要的组成部分, 因为go的核心-并发一定要用到这个.</span>
我们知道并发在很多时候都是要进行通信的. go语言的并发通信是推荐我们使用channel 来进行, 也就是基于消息传递模型的并发通信.
(1)创建channel.
go中的内置类型, 我们使用make(自定义类型使用new--返回对象指针)
ch := make(chan int)
这样就创建了一个channel, 当然我么也可以先声明, 在分配创建.
var ch chan int
ch = make(chan int)
(2)带缓冲
ch := make(chan int, 10)
上面的意思就是创建一个名为ch的channel, 里面的类型为int, 缓冲值为10.
什么是缓冲?
如果没有这个缓冲值, 我们在读取channel的时候, 一定要channel里面准备好, 否则就阻塞起来. 在写的时候, 一定要里面没有值, 否则也会阻塞. 将程序挂起, 死锁.
有了这个缓冲值, 我们如果channel里面有<=10值的时候 , 我么读取是不阻塞 , 即时返回的. 在里面的<10个的时候, 写入也是即时返回的. 这样就不会将程序挂起啦.
(3)我们也可以创建单向,和双向的channel. 这个是 根据 现有的channel创建的, 仅仅是加上一些约束.
(4)读channel
value := <-ch
(5)写channel
ch <- value
(6)range语法.
for one := range chOut {
//one的操作
}
上面的range要注意一下, 如果chOut在生产者放入数据之后, 没有显式关闭channel, 那么range会阻塞在该线程中.
因为range 不看到 channel的显式关闭, 是不会停止的.
解决方法有两个:
1 在数据放入channel后显式关闭.
close(chOut)
2 判断一下
for one := range chOut {
if i := len(chOut); i <= 0 {
break
}
}