【golang笔记】go_channel遍历和关闭(24)

package main

import (
 "fmt"
)

func main() {

 intChan := make(chan int, 3)
 intChan <- 100
 intChan <- 200
 close(intChan) // close
 //这是不能够再写入数到channel
 //intChan<- 300
 fmt.Println("大家好~")
 //当管道关闭后，读取数据是可以的
 n1 := <-intChan
 fmt.Println("n1=", n1) //n1= 100
 fmt.Println(<-intChan) //200
}

package main

import (
 "fmt"
)

func main() {
 //遍历管道
 intChan := make(chan int, 100)
 for i := 0; i < 100; i++ {
  intChan <- i * 2 //放入100个数据到管道
 }

 //遍历管道不要使用普通的 for 循环
 // close(intChan)
 // for i := 0; i < 100; i++ {
 //  fmt.Println(<-intChan)
 // }

// for i := 0; i < len(intChan); i++ {
 //  fmt.Println(<-intChan)
 // }
 //在遍历时，如果channel没有关闭，则会出现deadlock的错误
 //在遍历时，如果channel已经关闭，则会正常遍历数据，遍历完后，就会退出遍历
 close(intChan)
 for v := range intChan {
  fmt.Println("v=", v)
 }
}

package main

import (
 "fmt"
)

//write Data
func writeData(intChan chan int) {
 for i := 1; i <= 50; i++ {
  //放入数据
  intChan <- i //
  fmt.Println("writeData ", i)
 }
 close(intChan) //关闭
}

//read data
func readData(intChan chan int, exitChan chan bool) {
 for {
  v, ok := <-intChan
  if !ok {
   break
  }
  fmt.Printf("readData 读到数据=%v\n", v)
 }
 //readData 读取完数据后，即任务完成
 exitChan <- true
 close(exitChan)
}

func main() {

 //创建两个管道
 intChan := make(chan int, 10)
 exitChan := make(chan bool, 1)

 go writeData(intChan)
 go readData(intChan, exitChan)

 //这么写也可以，其实就是等待有一条数据进来就结束。
 //<-exitChan

 for {
  _, ok := <-exitChan
  if !ok {
   break
  }
 }
}