Golang:无缓冲和单向channel

前端之家收集整理的这篇文章主要介绍了Golang:无缓冲和单向channel前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

简介

初学golang很容易混淆无缓冲的chan和只有一个元素的chan,认为这两个是一回事,其实是完全不同的,make(chan int) 是同步的,只能同时读写,没有读写会一直阻塞;make(chan int,1)是异步的,第一个入队的不会阻塞

  1. c1:=make(chan int) 无缓冲
  2. c2:=make(chan int,1) 有缓冲

code

  1. package main
  2.  
  3. import (
  4. "fmt"
  5. "sync"
  6. )
  7.  
  8. var wt sync.WaitGroup
  9.  
  10. func OutChan(noBufChan <-chan int) {
  11.  
  12. //chan关闭后for退出循环,否则会死循环
  13. for v := range noBufChan {
  14. fmt.Println(v)
  15. }
  16.  
  17. wt.Done()
  18. }
  19.  
  20. func InChan(noBufChan chan<- int) {
  21.  
  22. for i := 0; i < 5; i++ {
  23. noBufChan <- i
  24. }
  25. //v := <-noBufChan //invalid operation: <-noBufChan (receive from send-only type chan<- int)
  26. close(noBufChan)
  27. wt.Done()
  28. }
  29.  
  30. func main() {
  31.  
  32. wt.Add(2)
  33.  
  34. //无缓冲的chan,同步方式,有读才能写入
  35. var noBufChan = make(chan int)
  36.  
  37. go InChan(noBufChan)
  38. go OutChan(noBufChan)
  39.  
  40. wt.Wait()
  41.  
  42. fmt.Println("goroute全部退出")
  43. }

猜你在找的Go相关文章