golang 的channel

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

<span style="font-family: Arial, Helvetica, sans-serif; background-color: rgb(255, 255, 255);">go语言的channel是非常重要的组成部分, 因为go的核心-并发一定要用到这个.</span>

我们知道并发在很多时候都是要进行通信的. go语言的并发通信是推荐我们使用channel 来进行, 也就是基于消息传递模型的并发通信. 

(1)创建channel.

go中的内置类型, 我们使用make(自定义类型使用new--返回对象指针)

ch := make(chan int)
这样就创建了一个channel, 当然我么也可以先声明, 在分配创建.

var ch chan int
ch = make(chan int)
(2)带缓冲

ch := make(chan int, 10)
上面的意思就是创建一个名为ch的channel, 里面的类型为int, 缓冲值为10.

什么是缓冲?
如果没有这个缓冲值, 我们在读取channel的时候, 一定要channel里面准备好, 否则就阻塞起来. 在写的时候, 一定要里面没有值, 否则也会阻塞. 将程序挂起, 死锁.

有了这个缓冲值, 我们如果channel里面有<=10值的时候 , 我么读取是不阻塞 , 即时返回的. 在里面的<10个的时候, 写入也是即时返回的. 这样就不会将程序挂起啦.

(3)我们也可以创建单向,和双向的channel. 这个是 根据 现有的channel创建的, 仅仅是加上一些约束.

(4)读channel

value := <-ch
(5)写channel
ch <- value
(6)range语法.

for one := range chOut {
        //one的操作
}
上面的range要注意一下, 如果chOut在生产者放入数据之后, 没有显式关闭channel, 那么range会阻塞在该线程中.

因为range 不看到 channel的显式关闭, 是不会停止的. 

解决方法有两个:

1 在数据放入channel后显式关闭. 

close(chOut)
2 判断一下

for one := range chOut {
	if i := len(chOut); i <= 0 {
		break
	}
}









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

本文来自:CSDN博客

感谢作者:qiya2007

查看原文:golang 的channel

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

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