goroutine

在java中我们要实现并发编程的时候,我们通常需要自己维护一个线程池,并且需要自己去包装一个又一个的任务,同时需要自己去调度线程执行任务并维护上下文切换,这一切通常会耗费程序员大量的心智。那么能不能有一种机制,程序员只需要定义很多个任务,让系统去帮助我们把这些任务分配到CPU上实现并发执行呢?

Go语言中的goroutine就是这样一种机制。goroutine的概念类似于线程,但是goroutine是由Go的运行时(runtime)调度和管理的。Go程序会智能的将goroutine中的任务合理的分配给每个CPUGo语言之所以被称为现代化的编程语言,就是因为它在语言层面已经内置了调度和上下文切换的机制。

<font style="color:rgb(68, 68, 68);">Go</font>语言编程中你不需要去自己写进程、线程、协程,你的技能包里只有一个技能–<font style="color:rgb(68, 68, 68);background-color:rgb(248, 248, 248);">goroutine</font>,当你需要让某个任务并发执行的时候,你只需要把这个任务包装成一个函数,开启一个<font style="color:rgb(68, 68, 68);background-color:rgb(248, 248, 248);">goroutine</font>去执行这个函数就可以了,就是这么简单粗暴。

使用goroutine

Go语言中使用<font style="color:rgb(68, 68, 68);background-color:rgb(248, 248, 248);">goroutine</font>非常简单,只需要在调用函数的时候在前面加上<font style="color:#F5222D;background-color:rgb(248, 248, 248);">go</font>关键字,就可以为一个函数创建一个<font style="color:rgb(68, 68, 68);background-color:rgb(248, 248, 248);">goroutine</font> 一个<font style="color:rgb(68, 68, 68);background-color:rgb(248, 248, 248);">goroutine</font>必定对应一个函数,可以创建多个<font style="color:rgb(68, 68, 68);background-color:rgb(248, 248, 248);">goroutine</font>去执行相同的函数。

启动单个goroutine

启动<font style="color:rgb(68, 68, 68);">goroutine</font>的方式非常简单,只需要在调用的函数(普通函数和匿名函数)前面加上一个<font style="color:rgb(68, 68, 68);background-color:rgb(248, 248, 248);">go</font>关键字。 举个例子如下
  1. func hello() {
  2. fmt.Println("Hello Goroutine!")
  3. }
  4. func main() {
  5. hello()
  6. fmt.Println("main goroutine done!")
  7. }
输出如下:
  1. $ go run main.go
  2. Hello Goroutine!
  3. main goroutine done!
这个示例中hello函数和下面的语句是串行的,执行的结果是打印完Hello Goroutine!后打印main goroutine done! 接下来我们在调用hello函数前面加上关键字go,也就是启动一个goroutine去执行hello这个函数。
  1. func main() {
  2. go hello() // 启动另外一个goroutine去执行hello函数
  3. fmt.Println("main goroutine done!")
  4. }
输出结果如下
  1. $ go run main.go
  2. main goroutine done!
为什么呢? 在程序启动时,Go程序就会为main()函数创建一个默认的goroutine 当main()函数返回的时候该goroutine就结束了,所有在main()函数中启动的goroutine会一同结束,main函数所在的goroutine就像是权利的游戏中的夜王,其他的goroutine都是异鬼,夜王一死它转化的那些异鬼也就全部GG了。 所以我们要想办法让main函数等一等hello函数,最简单粗暴的方式就是time.Sleep了。
  1. func main() {
  2. go hello() // 启动另外一个goroutine去执行hello函数
  3. fmt.Println("main goroutine done!")
  4. time.Sleep(time.Second)
  5. }
执行上面的代码你会发现
  1. $ go run main.go
  2. main goroutine done!
  3. Hello Goroutine!
首先为什么会先打印main goroutine done!是因为我们在创建新的goroutine的时候需要花费一些时间,而此时main函数所在的goroutine是继续执行的。

启动多个goroutine

在Go语言中实现并发就是这样简单,我们还可以启动多个goroutine。让我们再来一个例子: (这里使用了sync.WaitGroup来实现goroutine的同步)
  1. var wg sync.WaitGroup
  2. func hello(i int) {
  3. defer wg.Done() // goroutine结束就-1
  4. fmt.Println("Hello Goroutine!", i)
  5. }
  6. func main() {
  7. for i := 0; i < 10; i++ {
  8. wg.Add(1) // 启动一个goroutine就登记+1
  9. go hello(i)
  10. }
  11. wg.Wait() // 等待所有登记的goroutine都结束
  12. }
输出结果如下:
  1. $ go run main.go
  2. Hello Goroutine! 0
  3. Hello Goroutine! 1
  4. Hello Goroutine! 6
  5. Hello Goroutine! 8
  6. Hello Goroutine! 9
  7. Hello Goroutine! 3
  8. Hello Goroutine! 4
  9. Hello Goroutine! 2
  10. Hello Goroutine! 5
  11. Hello Goroutine! 7
多次执行上面的代码,会发现每次打印的数字的顺序都不一致。这是因为<font style="color:rgb(68, 68, 68);">10</font><font style="color:rgb(68, 68, 68);background-color:rgb(248, 248, 248);">goroutine</font>是并发执行的,而<font style="color:rgb(68, 68, 68);background-color:rgb(248, 248, 248);">goroutine</font>的调度是随机的。