1、代码
2、运行
3、解析
1、代码 buffer.go
1 package main
2
3 import (
4 "fmt"
5 "time"
6 )
7
8 func readThread(ch chan int) {
9 fmt.Println("read for reading...")
10 for i := range ch {
11 fmt.Println("get i : ", i)
12 if 20 == i {
13 break
14 }
15 time.Sleep(1e8)
16 }
17 fmt.Println("read over...")
18 }
19
20 func main() {
21 ch := make(chan int, 1024)
22 go readThread(ch)
23 time.Sleep(1e9 * 2)
24 for i := 1; i <= 20; i++ {
25 ch <- i
26 }
27 fmt.Println("waitting for reading...")
28 time.Sleep(1e9 * 3)
29 fmt.Println("over...")
30 }
2、运行
1 $ go run buffer.go
2 read for reading...
3 waitting for reading...
4 get i : 1
5 get i : 2
6 get i : 3
7 get i : 4
8 get i : 5
9 get i : 6
10 get i : 7
11 get i : 8
12 get i : 9
13 get i : 10
14 get i : 11
15 get i : 12
16 get i : 13
17 get i : 14
18 get i : 15
19 get i : 16
20 get i : 17
21 get i : 18
22 get i : 19
23 get i : 20
24 read over...
25 over...
3、解析
根据运行结果进行分析：
1）先运行的readThread读线程，读线程已经做好了读的准备，但此时channel中还没有数据，所以阻塞了。等待读动作。
2）主线程中，一次性向channel中写入大量数据，由于有缓冲机制，所以可以一次性的写入多个数据而不会阻塞。当主线程写完了数据，就开始等待读线程的读动作结束。
3）channel中开始有数据，读线程开始读数据，每0.1秒钟读取一个数据，一共读取20次。读取结束了，打印read over。
4）主线程等待的时间到了，返回，退出