Go 语言中 channel 使用总结

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

Go 语言中的 channel 是实现  goroutine 间无锁通信的关键机制,他使得写多线程并发程序变得简单、灵活、触手可得。下面就个人理解对 channel 使用过程中应该注意的地方进行一个简要的总结。

channel 分类: 不带缓存 channel, 带缓存 channel

(1)不带缓存 channel
语法: 
        (a)创建channel       
                 make(chan type)
                 e.g.   ch := make(chan int)
        (b)通信方式(由于chan操作类似于Queue,为便于理解这里用EnQueue,DeQueue来描述通信操作)
                 EnQueue:    ch <- typevar        DeQueue:   var :=  <- ch
                 e.g.    ch <- 1    v := <-ch
关键: 
         调用channel EnQueue 操作之后被阻塞住(不管channel是否为空),直到写的数据被读取掉。调用channel DeQueue 操作时,如果channel中有数据则被读出,如果为空则阻塞住,直到有人往里面EnQueue数据。

(2)带缓存 channel
语法: 
        (a)创建channel       
                make(chan type, size)
                e.g.  ch := make(chan int, 9)
        (b)通信方式
                 同不带缓存channel
关键: 
         当channel中元素小于等于channel size时,调用channel EnQueue 操作后数据被放入到缓存中(非阻塞);当channel满以后,如果再调用EnQueue操作就会被阻塞住直到有元素被DeQueue出来。调用channel DeQueue 操作时,如果channel 为空则阻塞住直到有人往里面EnQueue数据,否则直接DeQueue出元素。

Note: 需要特别注意的是两者对于range操作的区别:无缓存channel是EnQueue一个数据被range读一个;而带缓存channel是EnQueue满之后被range整个一起拿出来用(这个机制对于用户是透明的,用户看到的还是一个一个拿出来),或者timeout时间到之后即使channel没有满也会被range拿出来。另外,channel 关闭之后,循环读channel操作(e.g. for v:=range channel) 读完channel中剩余数据会自动跳出循环。

有疑问加站长微信联系(非本文作者)

本文来自:CSDN博客

感谢作者:u013148156

查看原文:Go 语言中 channel 使用总结

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

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