Go语言中的管道(Channel)总结

 1 // 声明方式，在此ElemType是指此管道所传递的类型
 2 var chanName chan ElemType
 3 // 声明一个传递类型为int的管道
 4 var ch chan int
 5 // 声明一个map，元素是bool型的channel
 6 var m map[string] chan bool
 7 
 8 // 定义语法,定义需要使用内置函数make()即可，下面这行代码是声明+定义一个整型管道
 9 ch := make(chan int)
10 // 事先定义好管道的size,下面这行代码定义管道的size为100
11 ch := make(chan int, 100)
12 
13 // 由管道中读写数据，<-操作符是与最左边的chan优先结合的
14 // 向管道中写入一个数据，在此需要注意：向管道中写入数据通常会导致程序阻塞,直到有
15 // 其他goroutine从这个管道中读取数据
16 ch<- value
17 // 读取数据，注意：如果管道中没有数据，那么从管道中读取数据会导致程序阻塞，直到有数据
18 value := <-ch
19 
20 // 单向管道
21 var ch1 chan<- float64     // 只能向里面写入float64的数据，不能读取
22 var ch2 <-chan int         // 只能读取int型数据
23 
24 // 关闭channel，直接调用close()即可
25 close(ch)
26 // 判断ch是否关闭，判断ok的值，如果是false,则说明已经关闭(关闭的话读取是不会阻塞的)
27 x, ok := <-ch

 1 package main
 2 import "fmt"
 3 
 4 func print() {
 5     fmt.Println("Hello world")
 6 }
 7 
 8 func main() {
 9     for i := 0; i < 10; i++ {
10         go print()
11     }
12 }
上面的代码意思大致是：使用协程来并行输出10次 "Hello world", 但是大家运行上面代码的时候，会发现不会有输出。这是因为虽然使用go关键字进行了协程的创建，但是还没有等到执行的时候，main函数已经退出来了，进程已经关闭，所以起来的协程也不会被执行。
如果你有C相关的多线程经验时，可已经将协程改为线程，之后调用线程的join方法，让主线程等待子线程执行完毕后再退出。而在Go语言中，我们可以利用管道的写入阻塞和读取阻塞来完成类似线程join的行为。代码如下所示：
 1 package main
 2 import "fmt"
 3 
 4 func print(ch chan int) {
 5     fmt.Println("Hello world")
 6     ch<- 1
 7 }
 8 
 9 func main() {
10     chs := make([]chan int)
11     for i := 0; i < 10; i++ {
12         chs[i] = make(chan int)
13         go print(chs[i])
14     }
15     
16     for _, ch := range(chs){
17         <-ch
18     }
19 }

1 func print(ch chan int){
2     ch<- 1
3     fmt.Println("Hello world")
4 }