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

Golang中的管道channel在几个典型语言中的实现

发布时间:2020-12-16 18:35:30 所属栏目:大数据 来源:网络整理
导读:用golang有一段时间了,Golang中的管道确实是一个神器,我们用生产者-消费者来描述其基本用法为: func P(queue chan- int){ for i:= 0; i 1000; i++{ queue - i }}func C(queue -chan int){ v := - queue}func main(){ queue := make(chan int,10) // 这里

用golang有一段时间了,Golang中的管道确实是一个神器,我们用生产者-消费者来描述其基本用法为:

func P(queue chan<- int){
    for i:= 0; i < 1000; i++{
        queue <- i
    }
}

func C(queue <-chan int){
    v := <- queue
}

func main(){
     queue := make(chan int,10)  // 这里的10表示管道的容量,根据应用的需求进行设置
     go P(queue)
     go C(queue)
}


上例中的管道的用途是:生产者向管道中添加数据,当管道被填满(上例中是10个数据)时,生产者阻塞(等待消费者消费);当管道中有数据时,消费者从管道中获取数据,否则,阻塞(等待生产者向其中添加数据)。

显然,golang的基于消息通讯的模式极大地简化了上述需求,在其它语言中实现起来需要锁和条件变量等,比较麻烦。

因为这个场景几乎在所有的项目中都会用到,最近特地实现了C++,java,C#三个版本,github地址为:https://github.com/ChenJohnson/Channel, 欢迎各位使用,如有错误,请各位及时反馈,谢谢!

(编辑:李大同)

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

    推荐文章
      热点阅读