channel 信道的创建
ci := make(chan int) // 整数类型的无缓冲信道
cj := make(chan int, 0) // 整数类型的无缓冲信道
cs := make(chan *os.File, 100) // 指向文件指针的带缓冲信道
channel 是带缓冲和阻塞的信道
默认情况下，在另一端准备好之前，发送和接收都会阻塞。这使得 goroutine 可以在没有明确的锁或竞态变量的情况下进行同步。
ch := make(chan int)
ch <- v // 将 v 送入 channel ch。
v := <-ch // 从 ch 接收，并且赋值给 v。
（“箭头”就是数据流的方向。）
goroutline配合channel, 以实现多线程的同步操作
向缓冲 channel 发送数据的时候，只有在缓冲区满的时候才会阻塞。当缓冲区清空的时候接受阻塞。
package main
import (
"log"
"time"
)
// 声明一个函数,
func add(a int, c chan int) {
log.Println("准备往管道添加:", a)
c <- a
}
func main() {
a := []int{1, 2, 3, 4, 5, 6}
// 声明了一个管道, 管道长度为0
c := make(chan int)
// 做两个循环, 开启多个协程
for _, v := range a[:len(a)/2] {
go add(v, c)
}
for _, v := range a[len(a)/2:] {
go add(v, c)
}
// 上面的chan是阻塞的, 每当这里取出一个值, 上面的协程才会继续再执行一次
var x, y, n int
for i := 0; i < len(a)/2; i++ {
n = <-c
log.Println("从管道取出:", n, "并加入到x中")
x += n
n = <-c
log.Println("从管道取出:", n, "并加入到y中")
y += n
}
time.Sleep(500 * time.Microsecond)
log.Printf("x:%d, y:%d, sum:%d", x, y, x+y)
}
打印的内容(执行的顺序每次不一, 但是sum的总和是一致的):
2018/06/03 15:50:14 准备往管道添加: 6
2018/06/03 15:50:14 从管道取出: 6 并加入到x中
2018/06/03 15:50:14 准备往管道添加: 2
2018/06/03 15:50:14 从管道取出: 2 并加入到y中
2018/06/03 15:50:14 准备往管道添加: 5
2018/06/03 15:50:14 从管道取出: 5 并加入到x中
2018/06/03 15:50:14 准备往管道添加: 1
2018/06/03 15:50:14 准备往管道添加: 3
2018/06/03 15:50:14 从管道取出: 1 并加入到y中
2018/06/03 15:50:14 从管道取出: 3 并加入到x中
2018/06/03 15:50:14 准备往管道添加: 4
2018/06/03 15:50:14 从管道取出: 4 并加入到y中
2018/06/03 15:50:14 x:14, y:7, sum:21
range 和 close
发送者可以 close 一个 channel 来表示再没有值会被发送了。接收者可以通过赋值语句的第二参数来测试 channel 是否被关闭：当没有值可以接收并且 channel 已经被关闭，那么经过
v, ok := <-ch
之后 ok 会被设置为 false。
循环 for i := range c 会不断从 channel 接收值，直到它被关闭。
注意： 只有发送者才能关闭 channel，而不是接收者。向一个已经关闭的 channel 发送数据会引起 panic。 还要注意： channel 与文件不同；通常情况下无需关闭它们。只有在需要告诉接收者没有更多的数据的时候才有必要进行关闭，例如中断一个 range。
package main
import "log"
func fibonacci(n int, c chan int) {
x, y := 0, 1
for i := 0; i < n; i++ {
c <- x
x, y = y, x+y
}
// close 关闭一个 channel
// close 只能由发送者(协程的函数)执行
close(c)
}
func main() {
c := make(chan int, 10)
go fibonacci(cap(c), c)
//还要注意： channel 与文件不同；通常情况下无需关闭它们。只有在需要告诉接收者没有更多的数据的时候才有必要进行关闭，例如中断一个 `range`
for v := range c {
log.Println(v)
}
}
参考资料:
http://go-tour-zh.appspot.com/
