golang学习笔记——Channel

Channel通道

• 无缓存通道  make(chan type类型)   注意：读和写都是阻塞执行的

package main   import (     "fmt"     "time" )   var ch = make(chan int)   func Printer(str string) {     for _, data := range str {          fmt.Printf("%c", data)          time.Sleep(time.Second)     }     fmt.Printf("\n") }   func Person1() {     Printer("hello")     ch <- 7 }   func Person2() {     <-ch //通道中获取不到数据时会阻塞等待     Printer("world") }     func main() {     go Person1()     go Person2()       for {     } }  

• 有缓存通道 make(chan type类型,容量)   注意：当channel中空间未满时是异步非阻塞

var ch = make(chan int,10)  

• 关闭channel  close()  注意：关闭后只能够读数据不能够写数据

package main   import (     "fmt" )   func main() {     ch := make(chan int)       go func() {          for i := 0; i < 5; i++ {                  ch <- i          }          close(ch)     }()       for {          if k, ok := <-ch; ok == true { //通过 ok 判断通道是否关闭                  fmt.Println(k)          } else {                  break          }     }       //可以使用 range 读取通道中的数据，通道关闭后自动跳出循环     for num := range ch {          fmt.Println(num)     }   }  

• 单向通道   make(chan<- type) 只写通道    make(<-chan int) 只读通道  注意:普通通道可以转为单向通道，单向不可以转为普通

package main   import (     "fmt" )   func producer(out chan<- int) {     for i := 0; i < 5; i++ {          out <- i * i     }     close(out) }   func consumer(in <-chan int) {     for num := range in {          fmt.Println(num)     } }   func main() {     ch := make(chan int)       go producer(ch)       consumer(ch) }