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

iosJohnson · · 2351 次点击 · · 开始浏览

这是一个创建于的文章，其中的信息可能已经有所发展或是发生改变。

用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，欢迎各位使用，如有错误，请各位及时反馈，谢谢！

有疑问加站长微信联系（非本文作者）