原文: https://www.jianshu.com/p/147bd63801b6安全
--------------------------------------并发
Go与其余语言不同,它从语言层面就已经支持并发,不须要咱们依托Thread库新建线程。Go中的channel机制使咱们不用过多考虑锁和并发安全问题。channel提供了一种goroutine之间数据流传输的方式。函数
今天我想从一个常见的deadlock error开始,讨论一下channel的特性。ui
若是运行如下程序:spa
var ch = make(chan int) func main() { ch <- 1 <-ch // 没有这行代码也会报一样的错误 }
terminal会报以下错误:.net
fatal error: all goroutines are asleep - deadlock!
回顾channel(信道)的概念,大体上来讲,信道是goroutine之间相互沟通的管道,信道中数据的流通表明着goroutine之间内存的共享。宏观上来说,信道有点像其余语言中的队列(queue),遵循先进先出的规则。线程
信道分为无缓冲信道(即unbuffered channel)和有缓冲信道(buffered channel)。对于无缓冲的信道来讲,咱们默认信道的发消息(send)和收消息(receive)都是阻塞(block)的。换句话来讲,无缓冲的信道在收消息和发消息的时候,goroutine都处于挂起状态。除非另外一端准备好,不然goroutine没法继续往下执行。code
上面的那段程序即是一个明显的错误样例。在main函数执行到ch <- 1的时候main(也是一个goroutine)便已挂起,而并无其余goroutine负责接收消息,而下面一句 <-ch 永远没法执行,系统便自动判为timeout返回error。这种全部线程或者进程都在等待资源释放的状况,咱们便把它称之为死锁。blog
死锁是一个很是有意思的话题,常见的死锁大体分为如下几类:
i. 只在单一goroutine里操做信道,例子如上。
ii. 串联信道中间一环挂起,举例以下:队列
var ch1 chan int = make(chan int) var ch2 chan int = make(chan int) func say(s string) { fmt.Println(s) ch1 <- <- ch2 // ch1 等待 ch2流出的数据 } func main() { go say("hello") <- ch1 // 堵塞主线 }
ch1等待ch2留出数据,然而ch2并无发出数据致使goroutine阻塞,解决方案是给ch2喂数据:
func feedCh2(ch chan int) { ch <- 2 }
iii. 非缓冲信道不成对出现:
c, quit := make(chan int), make(chan int) go func() { c <- 1 // c通道的数据没有被其余goroutine读取走,堵塞当前goroutine quit <- 0 // quit始终没有办法写入数据 }() <- quit // quit 等待数据的写
固然,并不是全部不成对出现的非缓冲信道都会报错:
func say(ch chan int) { ch <- 1 } func main() { ch := make(chan int) go say(ch) }
有意思的是,虽然say函数挂起等待信道接收消息,可是main goroutine并无被阻塞,在main函数返回后程序依然能够自动终止。
关于缓冲信道将会在以后的文章中介绍,若有意见还请指教。
Reference: http://blog.csdn.net/kjfcpua/article/details/18265441