golang语言并发与并行

zeromax

　　如果不是我对真正并行的线程的追求，就不会认识到Go有多么的迷人。
　　Go语言从语言层面上就支持了并发，这与其他语言大不一样，不像以前我们要用Thread库 来新建线程，还要用线程安全的队列库来共享数据。
　　以下是我入门的学习笔记。

Go语言的goroutines、信道和死锁

goroutine
　　Go语言中有个概念叫做goroutine, 这类似我们熟知的线程，但是更轻。
　　以下的程序，我们串行地去执行两次loop函数:
　　

func loop() {　　
for i := 0; i < 10; i++ {
　　
fmt.Printf("%d ", i)
　　
}
　　
}
　　

　　

　　
func main() {
　　
loop()
　　
loop()
　　
}
　　

　　

　　毫无疑问，输出会是这样的:
　　

0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9　　

　　下面我们把一个loop放在一个goroutine里跑，我们可以使用关键字go来定义并启动一个goroutine:
　　

func main() {　　
go loop() // 启动一个goroutine
　　
loop()
　　
}
　　

　　

　　这次的输出变成了:
　　

0 1 2 3 4 5 6 7 8 9　　

　　可是为什么只输出了一趟呢？明明我们主线跑了一趟，也开了一个goroutine来跑一趟啊。
　　原来，在goroutine还没来得及跑loop的时候，主函数已经退出了。
　　main函数退出地太快了，我们要想办法阻止它过早地退出，一个办法是让main等待一下:
　　

func main() {　　
go loop()
　　
loop()
　　
time.Sleep(time.Second) // 停顿一秒
　　
}
　　

　　

　　这次确实输出了两趟，目的达到了。
　　可是采用等待的办法并不好，如果goroutine在结束的时候，告诉下主线说“Hey, 我要跑完了！”就好了， 即所谓阻塞主线的办法，回忆下我们Python里面等待所有线程执行完毕的写法:
　　

for thread in threads:　　
thread.join()
　　

　　

　　是的，我们也需要一个类似join的东西来阻塞住主线。那就是信道

信道
　　信道是什么？简单说，是goroutine之间互相通讯的东西。类似我们Unix上的管道（可以在进程间传递消息）， 用来goroutine之间发消息和接收消息。其实，就是在做goroutine之间的内存共享。
　　使用make来建立一个信道:
　　

var channel chan int = make(chan int)　　
// 或
　　
channel := make(chan int)
　　

　　

　　那如何向信道存消息和取消息呢？ 一个例子:
　　

func main() {　　
var messages chan string = make(chan string)
　　
go func(message string) {
　　
messages