首先引用一句名言：
Don’t communicate by sharing memory; share memory by communicating.
（不要通过共享内存来通信，而应该通过通信来共享内存。）-Rob Pike
我是这样理解的：
网络异常，图片无法展示
|
1 简介
通道(chan)类似于一个队列，特性就是先进先出，多用于goruntine之间的通信
声明方式：
ch := make(chan int) 复制代码
放入元素：
ch <- 0 复制代码
取出元素：
elem1 := <-ch 复制代码
遍历元素：
for data := range ch { ... } 复制代码
2 最基本使用
func chanPlay01() { //声明一个chan，设置长度为3 ch1 := make(chan int, 3) //进channel ch1 <- 2 ch1 <- 1 ch1 <- 3 //出channel elem1 := <-ch1 elem2 := <-ch1 elem3 := <-ch1 //打印通道的值 fmt.Printf("The first element received from channel ch1: %v\n", elem1) fmt.Printf("The first element received from channel ch1: %v\n", elem2) fmt.Printf("The first element received from channel ch1: %v\n", elem3) //关闭通道 close(ch1) } 复制代码
3 引入panic()方法
func chanPlay03() { //声明一个chan，设置长度为3 ch1 := make(chan int, 2) //进channel ch1 <- 2 ch1 <- 1 ch1 <- 3 //出channel elem1 := <-ch1 elem2 := <-ch1 elem3 := <-ch1 //打印通道的值 fmt.Printf("The first element received from channel ch1: %v\n", elem1) fmt.Printf("The first element received from channel ch1: %v\n", elem2) //panic内置函数停止当前线程的正常执行goroutine panic(ch1) fmt.Printf("The first element received from channel ch1: %v\n", elem3) //关闭通道 close(ch1) } 复制代码
4 不同协程间通信
func main() { // 构建一个通道 ch := make(chan int) // 开启一个并发匿名函数 go func() { // 从3循环到0 for i := 3; i >= 0; i-- { // 发送3到0之间的数值 ch <- i // 每次发送完时等待 time.Sleep(time.Second) } }() // 遍历接收通道数据 for data := range ch { // 打印通道数据 fmt.Println(data) // 当遇到数据0时, 退出接收循环 if data == 0 { break } } }
