简介
初学golang很容易混淆无缓冲的chan和只有一个元素的chan,认为这两个是一回事,其实是完全不同的,make(chan int) 是同步的,只能同时读写,没有读写会一直阻塞;make(chan int,1)是异步的,第一个入队的不会阻塞
- c1:=make(chan int) 无缓冲
- c2:=make(chan int,1) 有缓冲
code
- package main
-
- import (
- "fmt"
- "sync"
- )
-
- var wt sync.WaitGroup
-
- func OutChan(noBufChan <-chan int) {
-
- //chan关闭后for退出循环,否则会死循环
- for v := range noBufChan {
- fmt.Println(v)
- }
-
- wt.Done()
- }
-
- func InChan(noBufChan chan<- int) {
-
- for i := 0; i < 5; i++ {
- noBufChan <- i
- }
- //v := <-noBufChan //invalid operation: <-noBufChan (receive from send-only type chan<- int)
- close(noBufChan)
- wt.Done()
- }
-
- func main() {
-
- wt.Add(2)
-
- //无缓冲的chan,同步方式,有读才能写入
- var noBufChan = make(chan int)
-
- go InChan(noBufChan)
- go OutChan(noBufChan)
-
- wt.Wait()
-
- fmt.Println("goroute全部退出")
- }