channel通道

目录

channel通道

channel介绍

 channel基本使用

有缓存通道和无缓存通道的区别

 通道的初始化，写入数据到通道，从通道读取数据及基本的注意事项

 channel的关闭和遍历

channel的关闭

为什么关闭

如何优雅地关闭通道

 channel的遍历

 channel的细节

关于channel的只读和只写

 select

---

channel介绍

1. channel本质是一个数据结构-队列【示意图】
2. 数据是先进先出
3. 线程安全，多goroutine访问时，不需要加锁，channel本身是线程安全的
4. channel是他有类型的，一个string类型的channel只能存放string类型的数据
5. 示意图：

 channel基本使用

对于一个intChan类型的变量来讲，intChan地址里面存放了一个16位的管道的地址

有缓存通道和无缓存通道的区别

1. 无缓存通道：发送方向通道发送数据时会阻塞，直到有接收方接收数据。接收方接收数据时也会阻塞，直到有发送方发送数据。这种通道保证了发送和接收的同步性，非常适合在goroutine之间进行数据交换和同步
2. 有缓存通道：创建时指定了一个固定大小的缓冲区，发送方向通道发送数据时如果缓冲区未满，则不会阻塞；接收方接受数据时如果缓冲区非空，则不会阻塞。这种通道允许发送和接收的处理速度不同步，提高程序的并发性能。

 通道的初始化，写入数据到通道，从通道读取数据及基本的注意事项

 

 channel的关闭和遍历

channel的关闭

使用内置函数close关闭channel，当channel关闭后，就不能再向channel写数据，但是仍然可以从该channel读取数据。通道的关闭问题并没有这么简单，错误的关闭通道将会引起panic。

为什么关闭

1. 告知接收方通道已经关闭：关闭通道可以让接受方知道不会再有新的数据发送过来，避免接收方无限等待新数据
2. 避免死锁：如果通道没有关闭，接收方会一直阻塞在接收操作上
3. 释放资源：对于使用缓存的通道关闭可以释放缓存区占用的内存。

如何优雅地关闭通道

1）遵守通道关闭原则

2）不要让通道的接收者关闭通道

这篇简书整理了一份关于通道关闭的方法及原则

 channel的遍历

注意：不能使用普通的for循环遍历

channel支持for-range的方式进行遍历

• 在遍历时，如果channel没有关闭，则会出现deadlock的错误
• 在遍历时，如果channel已经关闭，则会正常遍历数据，遍历完成后退出

 channel的细节

关于channel的只读和只写

func main() {//管道可以声明为只读或者只写//1.在默认情况下，管道是双向的//var chan1 chan int  可读可写//2.声明为只写var chan2 chan<- intchan2 = make(chan int, 3)chan2 <- 20//num := <-chan2  //error//3.声明为只读var chan3 <-chan intnum2 := <-chan3fmt.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)}//传统方法在遍历管道时，如果不关闭会导致死锁，但是在实际开发中可能不明确关闭管道的时间//解决办法：selectfor {select {//注意如果管道最终没有关闭，也不 会一直阻塞导致死锁//会自动到下一个case匹配case v := <-intChan:fmt.Printf("从intChan读取了数据%d\n", v)case v := <-stringChan:fmt.Printf("从stringChan读取了数据%s\n", v)default:fmt.Println("都取不到了")return}}}