今天我在遍历channel里的数据的时候加入了业务代码，业务代码里有return，一但return之后遍历就停止了，例如：

package main
import (
   "fmt"
   "sync"
   "time"
)
func consumer(cname string, ch chan int) {
   //可以循环 for i := range ch 来不断从 channel 接收值，直到它被关闭。
   for i := range ch {
      time.Sleep(1*time.Second)
      if i>20{
         return
      }
      fmt.Println("consumer-----------", cname, ":", i)
   }
   fmt.Println("ch closed.")
}

func producer(pname string, ch chan int) {
   for i := 0; i < 1000; i++ {
      //time.Sleep(1*time.Second)
      fmt.Println("producer--", pname, ":", i)
      ch <- i
   }
}


func main() {
   //用channel来传递"产品", 不再需要自己去加锁维护一个全局的阻塞队列
   ch := make(chan int,500)
   go producer("生产者", ch)
   for i:=0;i<5;i++  {
     go consumer("消费者", ch)
   }
   time.Sleep(1000 * time.Second)
   close(ch)
   time.Sleep(10 * time.Second)
}

i一旦大于20，从管道不断消费数据就停止了，所以遍历channel的时候不要放业务代码最好，放了是万万不能return的，当然panic同样也是不允许的。