天天看点

Go语言_并发篇理解什么是goroutine?goroutine的使用channel的使用channel的进一步理解:

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

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

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

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

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

f(11)

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

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

<a href="http://images.cnblogs.com/cnblogs_com/yjf512/201206/201206060955122621.png"></a>

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

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

这里就引进了channel的概念

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

上面的例子就可以改为:

<a href="http://images.cnblogs.com/cnblogs_com/yjf512/201206/201206060955132164.png"></a>

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

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

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

c &lt;- 1

是不是很形象

&lt;- c

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

<a href="http://blog.dccmx.com/2011/05/magic-of-channel-in-go/">http://blog.dccmx.com/2011/05/magic-of-channel-in-go/</a>

<a href="http://blog.dccmx.com/2012/03/small-problem-about-goroutine/">http://blog.dccmx.com/2012/03/small-problem-about-goroutine/</a>

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分别是这样的:

1

2

3

4

5

6

7

8

9

10

11

12

13

14

<code>var a string</code>

<code>var c = make(chan</code><code>int</code><code>,</code><code>10</code><code>)</code>

<code> </code> 

<code>func f() {</code>

<code>    </code><code>a =</code><code>"hello, world"</code>

<code>    </code><code>c &lt;-</code><code>0</code>

<code>}</code>

<code>func main() {</code>

<code>    </code><code>go f()</code>

<code>    </code><code>&lt;-c</code>

<code>    </code><code>print(a)</code>

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

<code>var c = make(chan</code><code>int</code><code>)</code>

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

本文转自轩脉刃博客园博客,原文链接:http://www.cnblogs.com/yjf512/archive/2012/06/06/2537712.html,如需转载请自行联系原作者

继续阅读