1. 无缓冲通道

 

 

 

2. 有缓冲通道

 

 

 有缓冲通道特点：当channel已经满，在向里面写数据就会阻塞，当channel已经为空，在从里面读数据就会阻塞。

 

3. 关闭channel

package main

import "fmt"

func main() {
   c := make(chan int)
   go func() {
      for i := 0; i < 5; i++ {
         c <- i
      }

      // close可以关闭一个channel
      close(c)
   }()

   for {
      // 当channel关闭，且数据都读完了，在读数据会读到该数据类型的零值，且第二个返回值为false
      if data, ok := <-c; ok {
         fmt.Println(data, ok)
      } else {
         fmt.Println(data, ok)
         break
      }
   }

   fmt.Println("Finished...")

}

/*
   1. channel不像文件一样需要经常去关闭，只有当你确实没有任何数据发送了，或者你想显示的结束range循环之类的，才去关闭channel
   2. 关闭channel后，无法向channel在发送数据（引发panic错误后导致接收立即返回0值）
   3. 关闭channel后，可以继续从channel接收数据
   4. 对于 nil channel，无论收发都会被阻塞
*/


4. channel与range

package main

import "fmt"

func main() {
	c := make(chan int)
	go func() {
		for i := 0; i < 5; i++ {
			c <- i
		}

		// close可以关闭一个channel
		close(c)
	}()

	// 如果c没有数据，range会阻塞等待，如果有数据会执行作用域里面的代码 
	// 如果c没有数据而且c已经关闭了，那么循环结束
	for v := range c {
		fmt.Println(v)
	}

	fmt.Println("Finished...")

}

　　

5. channel 与 select 实现fibonacci

package main

import "fmt"

func main() {
	c := make(chan int)
	quit := make(chan int)

	go func() {
		for i := 0; i < 10; i++ {
			fmt.Println(<-c)
		}

		quit <- 0
	}()

	fibonacci(c, quit)

}

func fibonacci(c, quit chan int) {
	x, y := 0, 1
	for {
		select {
		case c <- x:
			x, y = y, x + y
		case <-quit:
			fmt.Println("quit")
			return
		}
	}
}