加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 大数据 > 正文

golang编写一个简单的生成消费模式

发布时间:2020-12-16 18:16:23 所属栏目:大数据 来源:网络整理
导读:生成消费模式大家在现实生活中经常遇到,如果使用java编写可以使用阻塞队列如BlockingQueue,Python也有相应的组件,如果使用golang编写使用自带的channel管道更加简单。 下面直接看代码: package main import "fmt" func consumer(ch chan int ,done chan

生成消费模式大家在现实生活中经常遇到,如果使用java编写可以使用阻塞队列如BlockingQueue,Python也有相应的组件,如果使用golang编写使用自带的channel管道更加简单。
下面直接看代码:

package main

import "fmt"

func consumer(ch chan int,done chan string)  {
    for i := range ch{
        fmt.Println("recive",i)
    }
    done<-"ok"

}
func product(ch chan int) {
    for i := 0; i<5; i++{
        ch<-i
    }
    close(ch)
}

func main() {
    fmt.Println("start")
    ch := make(chan int)
    done := make(chan string)
    go consumer(ch,done)
    go product(ch)

    <-done

}

代码非常简单,分别用goroutine启动两个协程:生产和消费。共享ch,一个往管道中写数据一个往管道中读数据,done是为了让主进程等待消费者结束。

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读