over-golang/02-并发编程/03-channel的操作.md

三 channel的相关操作

3.1 通道数据的遍历

channel只支持 for--range 的方式进行遍历：

	ch := make(chan int)

	go func() {
		for i := 0; i <=3; i++ {
			ch <- i
			time.Sleep(time.Second)
		}
	}()

	for data := range ch {
		fmt.Println("data==", data)
		if data == 3 {
			break
		}
	}

3.2 通道关闭

通道是一个引用对象，支持GC回收，但是通道也可以主动被关闭：

	ch := make(chan int)
	close(ch)				// 关闭通道
	ch <- 1					// 报错：send on closed channel

从通道中接收数据时，可以利用多返回值判断通道是否已经关闭：

func main() {

	ch := make(chan int, 10)

	go func(ch chan int) {
		for i := 0; i < 10; i++ {
			ch <- i
		}
		close(ch)
	}(ch)

	for {
		if num, ok := <-ch; ok == true {
			fmt.Println("读到数据：", num)
		} else {
			break
		}
	}
} 

如果channel已经关闭，此时需要注意：

• 不能再向其写入数据，否则会引起错误：panic:send on closed channel
• 可以从已经关闭的channel读取数据，如果通道中没有数据，会读取通道存储的默认值

3.3 通道读写

默认情况下，管道的读写是双向的，但是为了对 channel 进行使用的限制，可以将 channel 声明为只读或只写。

	var chan1 chan<- int		// 声明 只写channel
	var chan2 <-chan int 		// 声明 只读channel

单向chanel不能转换为双向channel，但是双向channel可以隐式转换为任意类型的单向channel：

// 只写端
func write(ch chan<- int) {
	ch <- 100
	fmt.Printf("ch addr：%v\n", ch) // 输出内存地址
	ch <- 200
	fmt.Printf("ch addr：%v\n", ch) // 输出内存地址
	ch <- 300                      // 该处数据未读取，后续操作直接阻塞
	fmt.Printf("ch addr：%v\n", ch) // 没有输出
}

// 只读端
func read(ch <-chan int) {
	// 只读取两个数据
	fmt.Printf("取出的数据data1：%v\n", <-ch) // 100
	fmt.Printf("取出的数据data2：%v\n", <-ch) // 200
}

func main() {

	var ch chan int         // 声明一个双向
	ch = make(chan int, 10) // 初始化

	// 向协程中写入数据
	go write(ch)

	// 向协程中读取数据
	go read(ch)

	// 防止主go程提前退出，导致其他协程未完成任务
	time.Sleep(time.Second * 3)
}

双向channel进行显式转换：

	ch := make(chan int)		// 声明普通channel
	ch1 := <-chan int(ch)		// 转换为 只读channel
	ch2 := chan<- int(ch)		// 转换为 只写channel