golang生产者与消费者

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

使用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生产者与消费者

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

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