Goroutine

Goroutine 是 Go 语言特有的并发体，是一种轻量级的线程，由 go 关键字启动。在真实的 Go 语言的实现中，goroutine 和系统线程也不是等价的。尽管两者的区别实际上只是一个量的区别，但正是这个量变引发了 Go 语言并发编程质的飞跃。

协程的设计隐藏了线程创建和管理的诸多复杂性，在多线程操作系统上可实现多路复用，因此若一个线程阻塞，比如说等待 IO，那么其它的线程就会运行。不过即便协程相对轻量，但是也并不意味着可以无限制地开协程。一个很典型的例子，比如在 CPU 密集型的计算中，开出超过 CPU 核心（线程）数的协程并不能加快计算速度，可能反而会适得其反。

定义与使用

简单来说，gotoutine 是一个并发的函数（记住：不一定是并行）和其他代码一起运行。你可以简单的通过将 go 关键字放在函数前面来启动它：

func main() {
	go sayHello()
	// continue doing other things
}

func sayHello() {
	fmt.Println("hello, world")
}

执行 go sayHello() 语句创建 Goroutine 和 sayHello 函数是在同一个 Goroutine 中执行, 根据语句的书写顺序可以确定 Goroutine 的创建发生在 sayHello 函数返回之前, 但是新创建 Goroutine 对应的 f() 的执行事件和 sayHello 函数返回的事件则是不可排序的，也就是并发的。调用 sayHello 可能会在将来的某一时刻打印 “hello, world”，也很可能是在 sayHello 函数执行完成后才打印。

对于匿名函数，同样也能这么干，从下面这个例子你可以看得很明白。在下面的例子中，我们不是从一个函数建立一个 goroutine，而是从一个匿名函数创建一个 goroutine：

go func() {
    fmt.Println("hello")
}()// 1
// continue doing other things

注意这里的 ()，我们必须立刻调用匿名函数来使 go 关键字有效。或者，你可以将函数分配给一个变量，并像这样调用它：

sayHello := func() {
	fmt.Println("hello")
}
go sayHello()
// continue doing other things

Go Concurrency Patterns

我们可以通过 go myfunc() 轻易的创建一个和当前协程并发执行的 task。但是，当程序变复杂，go statement 变的越来越多时，就会遇到各种 task 生命周期的问题。

这个任务什么时候开始，什么时候结束？
怎么做到当所有子任务都结束，主任务再结束？
假如某个子任务失败，主任务如何终止掉其他子任务？
如何保证所有子任务在某个特定的超时时间内返回，无论它成功还是失败？
更进一步，如何保证主任务在规定的时间内返回，无论其成功还是失败，同时终止掉它产生的所有子任务？
主任务已经结束了，子任务还在运行，是不是存在资源泄漏？

当然这些问题在 Golang 里面都是可以解的，具体可以参考 Golang Official Blog 里几篇讲 Golang Concurrency Patterns 的文章。它需要程序按照一些特定的行为方式去组织，比如说方法参数带上 Context，通过它去传递 cancellation 信号。

最近更新于 0001-01-01