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, 欢迎各位使用,如有错误,请各位及时反馈,谢谢! (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |