Goland 通道

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<- 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
       }
    }

}