zeromax 发表于 2018-9-21 07:23:52

golang语言并发与并行

  如果不是我对真正并行的线程的追求,就不会认识到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
页: [1]
查看完整版本: golang语言并发与并行