channel

2022-08-30 13:00:48 阅读：146 来源： 互联网

channel有缓冲与无缓冲同步问题

package main

import (
   "fmt"
   "time"
)

func main() {
   c := make(chan int, 3) //带有缓冲的channel

   fmt.Println("len(c) = ", len(c), ", cap(c)", cap(c))

   go func() {
      defer fmt.Println("子go程结束")

      for i := 0; i < 4; i++ {
         c <- i
         fmt.Println("子go程正在运行, 发送的元素=", i, " len(c)=", len(c), ", cap(c)=", cap(c))
      }
   }()
   time.Sleep(2 * time.Second)
   for i := 0; i < 4; i++ {
      num := <-c //从c中接收数据，并赋值给num
      fmt.Println("num = ", num)
   }
   fmt.Println("main 结束")
}

关闭channel

package main

import "fmt"

func main() {
   c := make(chan int)

   go func() {
      for i := 0; i < 5; i++ {
         c <- i
         //close可以关闭一个channel
         close(c)
      }
   }()
   
   for {
      //ok如果为true表示channel没有关闭，如果为false表示channel已经关闭
      if data, ok := <-c; ok {
         fmt.Println(data)
      } else {
         break
      }
   }

   fmt.Println("Main Finished..")
}

标签：缓冲,fmt,func,go,main,channel
来源： https://www.cnblogs.com/suehoo/p/16638896.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

channel