golang生产者与消费者

u012798391 · · 1737 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

                                                                                                     

使用golang可以很容易实现,生产者与消费者功能。

实现一:(只生产一定数量数据)


//写入专用通道 //一次写10条 func produce(p chan<- int) {  for i := 0; i < 10; i++ {   p <- i //主线程不能产生死锁,所以此处报错   fmt.Println("send:", i)  } }  //消费专用通道 //一次只取10条 func consumer(c <-chan int) {  for i := 0; i < 10; i++ {   v := <-c   fmt.Println("receive:", v)  } }


调用:



ch := make(chan int) //只生产和消费10条记录 go produce(ch) go consumer(ch)


实现二:(自动生产与消费)



//自动消费 func autoConsumer(ch <-chan int)  {     for{         select {         case   ws:=<-ch:             fmt.Println( "fmt print" , ws)         default:             time.Sleep(1000*time.Millisecond)         }     } }


调用:



ch := make(chan int)  //持续生产与消费, high起来 go func() {     for{    //不断生产,一次10条         produce(ch)     } }() go autoConsumer(ch)


注意:为了保持主进程程不死掉,在main函数最下面加上这句。



for  {         //心跳         time.Sleep(time.Second) }


祝好


本文来自:CSDN博客

感谢作者:e421083458

查看原文:golang生产者与消费者




查看原文:http://www.zoues.com/2016/10/20/golang%e7%94%9f%e4%ba%a7%e8%80%85%e4%b8%8e%e6%b6%88%e8%b4%b9%e8%80%85/

有疑问加站长微信联系(非本文作者)

本文来自:CSDN博客

感谢作者:u012798391

查看原文:golang生产者与消费者

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

1737 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传