博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
go17---并发
阅读量:5999 次
发布时间:2019-06-20

本文共 1844 字,大约阅读时间需要 6 分钟。

yjf512 · 
2015-02-21 11:09:07 · 1076 次点击 · 预计阅读时间 2 分钟 · 大约1分钟之前 开始浏览    
这是一个创建于 
2015-02-21 11:09:07 的文章,其中的信息可能已经有所发展或是发生改变。

当被问到为什么用Go语言,一定不得不提的是Go语言的并发程序编写。在C语言中编写非常繁琐复杂的并发程序在Go语言中总是显得如此便捷。

Go中并发程序依靠的是两个:goroutine和channel

理解什么是goroutine?

对于初学者,goroutine直接理解成为线程就可以了。当对一个函数调用go,启动一个goroutine的时候,就相当于起来一个线程,执行这个函数。

实际上,一个goroutine并不相当于一个线程,goroutine的出现正是为了替代原来的线程概念成为最小的调度单位。一旦运行goroutine时,先去当先线程查找,如果线程阻塞了,则被分配到空闲的线程,如果没有空闲的线程,那么就会新建一个线程。注意的是,当goroutine执行完毕后,线程不会回收推出,而是成为了空闲的线程。

关于goroutine的理解,推荐看这个帖子:

goroutine的使用

使用非常简单,在函数前增加一个go

 

f(11)

go f(11) //这个是让f()函数作为goroutine运行

 

但是go有一个缺点,主线程要等待一个goroutine结束再处理怎么办?拿《学习go语言》中的一个例子说明。

这里的第18行为什么要sleep? 这里是为了等上面两个go ready处理完成。

 

好了,这里就出来了一个需求:一个goroutine结束后必须要向主线程传输数据,告诉主线程这个goroutine已经结束了。

 

这里就引进了channel的概念

channel的使用

channel的意思用白话可以这么理解:主线程告诉大家你开goroutine可以,但是我在我的主线程开了一个管道,你做完了你要做的事情之后,往管道里面塞个东西告诉我你已经完成了。

上面的例子就可以改为:

从这个程序得到的几点信息:

1 channel只能使用make来进行创建

基本格式是 c := make(chan int)

int是说明这个管道能传输什么类型的数据

2 往channel中插入数据的操作

c <- 1

是不是很形象

3 从channel中输出数据

<- c

4 为什么需要输出两次(4和5两行?)

因为2和3启动了两个goroutine,每个goroutine都往管道输出一个1,因此主线程要接收两次才能说明两个goroutine都结束了

channel的进一步理解:

 

channel分为两种:一种是有buffer的,一种是没有buffer的,默认是没有buffer的

ci := make(chan int) //无buffer

cj := make(chan int, 0) //无buffer

cs := make(chan int, 100) //有buffer

有缓冲的channel,因此要注意“放”先于“取”

无缓冲的channel,因此要注意“取”先于“放”

 里面的一个例子很好:

 

同样要先输出hello world,使用有缓冲的channel和无缓冲的channel分别是这样的:

有缓冲的channel:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
var a string
var c = make(chan
int
,
10
)
  
func f() {
    
a =
"hello, world"
    
c <-
0
}
  
func main() {
    
go f()
    
<-c
    
print(a)
 
}

这里有个缓冲,因此放入数据的操作c<- 0先于取数据操作 <-c

无缓冲的channel:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
var a string
var c = make(chan
int
)
  
func f() {
    
a =
"hello, world"
    
<-c
}
  
func main() {
    
go f()
    
c <-
0
    
print(a)
 
}

由于c是无缓冲的channel,因此必须保证取操作<-c 先于放操作c<- 0

本文转自农夫山泉别墅博客园博客,原文链接:http://www.cnblogs.com/yaowen/p/8082918.html,如需转载请自行联系原作者

你可能感兴趣的文章
博客园个性时钟,Play with me !!!
查看>>
HDU 5366 The mook jong
查看>>
Unity ScriptableObject自定义属性显示
查看>>
【开源】简单4步搞定QQ登录,无需什么代码功底【无语言界限】
查看>>
ORACLE内存管理之ASMM AMM
查看>>
移动前端常用meta标签
查看>>
非结构化数据与结构化数据提取---多线程爬虫案例
查看>>
splay版
查看>>
unity 打包编译记录
查看>>
CSS知识总结(四)
查看>>
软件工程第一次作业
查看>>
22. Generate Parentheses
查看>>
MDL相关总结
查看>>
抓取代理IP
查看>>
【Matlab 】【转】元胞数组--cell
查看>>
python2.7.2文档阅读笔记
查看>>
jQuery技巧之让任何组件都支持类似DOM的事件管理
查看>>
Python中模块的发布与安装
查看>>
cc2530 timer 3 PWM <可调占空比>
查看>>
Centos 修改limits.conf open files后不生效的解决办法
查看>>