Goroutine和channel是Go在“并发”方面两个核心feature。我自己在使用golang开发时会被常会被channel所困扰。废话不多说,正题开始.
那么golang的channel是什么?
简单说他可以让goroutine之间互相通信,通俗讲我可以通过channel传递信息给goroutine。 我可以通过channel来控制调度goroutine。
那么channel有几个分类?
对于golang的channel的基础我还是有些了解的,channel主要有两类,一类是无缓冲,一类是有缓冲 。
缓冲信道: var ch chan int = make(chan int, 2) 无缓冲信道: var ch chan int = make(chan int)
该文章写的有些乱,欢迎来喷 ! 另外文章后续不断更新中,请到原文地址查看更新。
如果channel是无缓冲的,接收方会一直阻塞直到有数据到来。发送方会一直阻塞直到接收方将数据取出。如果channel带有缓冲区,发送方会一直阻塞直到数据被拷贝到缓冲区;如果缓冲区已满,则发送方只能在接收方取走数据后才能从阻塞状态恢复。
channel信道的输入输出一般是成对出现的,如果不成对那边就会出现死锁的情况。 有时候死锁不会中断程序,但是会影响后面的逻辑的执行,也就是会一直阻塞。
但是我下面的例子明明没有使用channel,为什么会出现死锁的情况.
package main //xiaorui.cc import ( "fmt" "time" ) func main() { go func() { num := 1 for { fmt.Println(num) time.Sleep(1e9) num++ if num == 10 { break } } }() select {} }
出现的结果. fatal error: all goroutines are asleep – deadlock!
`go run g.go` | done: 9.355421943s ] 1 2 3 4 5 6 7 8 9 fatal error: all goroutines are asleep - deadlock! goroutine 1 [select (no cases)]: main.main() /Users/ruifengyun/g.go:40 +0x30 exit status 2 exit status 1 [ ~/ ] #
这个问题需要从两个地方来解释:
第一, select{}的用途,原本以为select{}是用来阻塞goroutine协程的,但select{}会监听io事件,也就是说我这里的select{}需要添加channel接受,在go执行的函数里也要传递信息给channel。
第二,这个实例脚本明显不是那种一直跑的服务,而是个脚本。 重点在于我们会在脚本退出前确保goroutine执行完。 这就需要使用go的同步阻塞模式。
golang的同步阻塞有channel跟sync两种方式。
我们先来channel select监听io的方式。
// xiaorui.cc t := make(chan int, 1) go func() { num := 1 for { fmt.Println(num) time.Sleep(1e9) num++ if num == 3 { break } } t <- 1 }() select { case <-t: fmt.Println("end...") }
下面是sync.WaitGroup实现的阻塞同步方式。
var wg sync.WaitGroup t := "http://xiaorui.cc" wg.Add(1) go func() { num := 1 for { fmt.Println(num) time.Sleep(1e9) num++ if num == 3 { break } } defer wg.Done() }() wg.Wait() fmt.Println("over")
废话一句,go channel要根据自己的环境选择channel种类。 Golang的goroutine不会遇到堵塞的问题,但配合channel使用时问题就多了,所以说一定要区分出无缓冲信道和缓冲信道的区别。