channel通道
目录
channel通道
channel介绍
channel基本使用
有缓存通道和无缓存通道的区别
通道的初始化，写入数据到通道，从通道读取数据及基本的注意事项
channel的关闭和遍历
channel的关闭
为什么关闭
如何优雅地关闭通道
channel的遍历
channel的细节
关于channel的只读和只写
select
channel介绍
- channel本质是一个数据结构-队列【示意图】
- 数据是先进先出
- 线程安全，多goroutine访问时，不需要加锁，channel本身是线程安全的
- channel是他有类型的，一个string类型的channel只能存放string类型的数据
- 示意图：
channel基本使用
对于一个intChan类型的变量来讲，intChan地址里面存放了一个16位的管道的地址
有缓存通道和无缓存通道的区别
- 无缓存通道：发送方向通道发送数据时会阻塞，直到有接收方接收数据。接收方接收数据时也会阻塞，直到有发送方发送数据。这种通道保证了发送和接收的同步性，非常适合在goroutine之间进行数据交换和同步
- 有缓存通道：创建时指定了一个固定大小的缓冲区，发送方向通道发送数据时如果缓冲区未满，则不会阻塞；接收方接受数据时如果缓冲区非空，则不会阻塞。这种通道允许发送和接收的处理速度不同步，提高程序的并发性能。
通道的初始化，写入数据到通道，从通道读取数据及基本的注意事项
channel的关闭和遍历
channel的关闭
使用内置函数close关闭channel，当channel关闭后，就不能再向channel写数据，但是仍然可以从该channel读取数据。通道的关闭问题并没有这么简单，错误的关闭通道将会引起panic。
为什么关闭
- 告知接收方通道已经关闭：关闭通道可以让接受方知道不会再有新的数据发送过来，避免接收方无限等待新数据
- 避免死锁：如果通道没有关闭，接收方会一直阻塞在接收操作上
- 释放资源：对于使用缓存的通道关闭可以释放缓存区占用的内存。
如何优雅地关闭通道
1）遵守通道关闭原则
2）不要让通道的接收者关闭通道
这篇简书整理了一份关于通道关闭的方法及原则
channel的遍历
注意：不能使用普通的for循环遍历
channel支持for-range的方式进行遍历
- 在遍历时，如果channel没有关闭，则会出现deadlock的错误
- 在遍历时，如果channel已经关闭，则会正常遍历数据，遍历完成后退出
channel的细节
关于channel的只读和只写
func main() {
//管道可以声明为只读或者只写
//1.在默认情况下，管道是双向的
//var chan1 chan int 可读可写
//2.声明为只写
var chan2 chan<- int
chan2 = make(chan int, 3)
chan2 <- 20
//num := <-chan2 //error
//3.声明为只读
var chan3 <-chan int
num2 := <-chan3
fmt.Println("num2", num2)
}只读只写不代表它的类型，只代表了它的属性
select
使用select可以解决从通道取数据的阻塞问题
func main() {
//使用select可以解决从管道取数据的阻塞问题
//1.定义一个 管道 10个数据 int类型
//2.定义一个 管道 5个数据 string类型
intChan := make(chan int, 10)
for i := 0; i < 10; i++ {
intChan <- i
}
stringChan := make(chan string, 5)
for i := 0; i < 5; i++ {
stringChan <- "hello" + fmt.Sprintf("%d", i)
}
//传统方法在遍历管道时，如果不关闭会导致死锁，但是在实际开发中可能不明确关闭管道的时间
//解决办法：select
for {
select {
//注意如果管道最终没有关闭，也不 会一直阻塞导致死锁
//会自动到下一个case匹配
case v := <-intChan:
fmt.Printf("从intChan读取了数据%d\n", v)
case v := <-stringChan:
fmt.Printf("从stringChan读取了数据%s\n", v)
default:
fmt.Println("都取不到了")
return
}
}
}
