Go語言基礎(chǔ)并發(fā)channel

這篇文章主要講解了“Go語言基礎(chǔ)并發(fā)channel”，文中的講解內(nèi)容簡單清晰，易于學(xué)習(xí)與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學(xué)習(xí)“Go語言基礎(chǔ)并發(fā)channel”吧！

為什么需要channel

channel在Go中，也叫做管道，是用來多線程之間共享數(shù)據(jù)的。

通常情況下，在Go中共享數(shù)據(jù)用的也是channel，但是在Go有兩種共享數(shù)據(jù)方式。

• 共享內(nèi)存實(shí)現(xiàn)通訊。

• 通過管道(channel)通訊(推薦)。

為啥子共享內(nèi)存通訊不太推薦?

示例代碼:多線程修改一個(gè)值。

函數(shù)

func Calc() {     defer wg.Done()     NUM = NUM - 1 }

main

var NUM = 100 var wg sync.WaitGroup  func main() {     for i := 0; i<100;i++  {         wg.Add(1)         go Calc() }     wg.Wait()     fmt.Println(NUM) }

執(zhí)行結(jié)果

沒錯(cuò)，是2，懵了吧，哈哈哈，理論應(yīng)該是0才對呀。

這是為啥?

這就是共享內(nèi)存不太推薦的原因，我們的代碼已經(jīng)是多線程了。

在第一個(gè)函數(shù)代碼中，第3行，NUM = NUM - 1。

如果多個(gè)線程同時(shí)執(zhí)行到這一行，并且沒有加鎖，就會出現(xiàn)數(shù)據(jù)錯(cuò)亂。

那該怎么做呢?

加鎖，加鎖可以保證某一段代碼只能被一個(gè)線程執(zhí)行，防止被爭搶。

代碼

func Calc() {     defer wg.Done()     mutex.Lock()     NUM = NUM - 1     mutex.Unlock() }

第3行加鎖，第5行解鎖。

執(zhí)行結(jié)果

這次真的是0的，不管執(zhí)行幾次。

但是會發(fā)現(xiàn)一個(gè)問題，如果采用這種方式，需要常常注意競爭問題。

所以不是太推薦，需要考慮的比較多，并且各種加鎖會消耗性能。

channel語法

channel格式

var 變量名 chan 類型 例如 var x1 chan int //x1管道里面只能存int類型數(shù)據(jù) var x2 chan string //x2管道里面只能存字符串類型數(shù)據(jù)

注意

定義管道時(shí)，chan int是一個(gè)整體，別搞錯(cuò)了各位。

創(chuàng)建channel

創(chuàng)建channel，只能通過make創(chuàng)建。

格式

var 變量名 = make(chan 類型，[管道大小]) 示例 var chan1 = make(chan int，10)//管道可以放10個(gè)int元素 var chan2 = make(chan string，5)//管道可以放5個(gè)string元素

channel操作

創(chuàng)建一個(gè)管道。

ch = make(chan int，10)

channel是一個(gè)管道，就像一個(gè)管子。

所以可以像管子里面塞東西，并且能取東西，關(guān)閉管道就是這個(gè)管道不能用了，里面的值取完就打樣了。

像管子塞東西(發(fā)送)ch <- 666。

從管子取東西(接收)var x = <- ch。

關(guān)閉管子close(ch)。

注意:channel是先入先出結(jié)構(gòu)，就像這樣。

 

注意事項(xiàng):

• 如果通道塞滿了，再塞 會阻塞住。

• 如果通道關(guān)閉了，是不能再塞值了，否則會panic。

• 即使通道關(guān)閉了，依然可以取值，直到將管道的值取完，取完后得到的是對應(yīng)類型零值。

• 管道不能重復(fù)關(guān)閉，重復(fù)關(guān)閉會panic。

無緩沖管道

無緩沖就是這個(gè)管道沒有長度，就像這樣。

就像快讀員沒有快遞柜，需要直接將快遞給客戶，如果沒人要就撂攤子。

示例代碼

package main  import (     "fmt" )  //模擬張三 func 張三(x chan string) {     var a = <-x     fmt.Println(a) }  func main() {     //通道沒有長度，就是無緩沖通道     var x = make(chan string)     go 張三(x)     x <- "張三的快遞"     fmt.Println("張三快遞交付成功") }

第16行寫入一個(gè)值，同理，張三就要等著去接，如果沒人接，那就完了。

假設(shè)注釋第9行代碼。

直接報(bào)錯(cuò)，all goroutines are asleep - deadlock!，這句話的意思是所有的協(xié)程都睡著了，死鎖

無緩沖說明通道長度為0，發(fā)送一個(gè)值會阻塞住。

這就相當(dāng)于快遞員直接找張三，但是張三沒了，但是快遞員還得一直等著，等等等，然后掛了，終究還是沒送出去。

有緩沖管道

這個(gè)就簡單啦，多了一個(gè)快遞柜，快遞員直接將快遞仍快遞柜就行了。

示例代碼

package main  import (     "fmt"     "sync" )  var wg sync.WaitGroup  //快遞員，快遞員放10個(gè)快遞 func 快遞員(kuaidigui chan string) {     defer wg.Done()     for i := 0; i < 10; i++ {         fmt.Println("快遞員放入了第"，i，"快遞")         kuaidigui <- fmt.Sprintf("第%d個(gè)快遞"， i) }     //放完快遞就關(guān)閉了通道     close(kuaidigui) }  //張三，拿走3個(gè)快遞 func 張三(kuaidigui chan string) {     defer wg.Done()     for i := 0; i < 3; i++ {         fmt.Println("張三拿走" + <-kuaidigui) } } //李四拿走7個(gè)快遞 func 李四(kuaidigui chan string) {     defer wg.Done()     for i := 0; i < 7; i++ {         fmt.Println("李四拿走" + <-kuaidigui) } } func main() {     //快遞柜，10個(gè)大小     var 快遞柜 = make(chan string， 10)     wg.Add(3)     go 快遞員(快遞柜)     go 張三(快遞柜)     go 李四(快遞柜)     wg.Wait() }

執(zhí)行結(jié)果

 

遍歷channel兩種方式

代碼

func main() {     //快遞柜，10個(gè)大小     var ch = make(chan int， 10)     //向管道中發(fā)送值     for i := 0; i < 10; i++ {         ch <- i }     //方式一取值     //for {     //i， ok := <-ch     ////取完值ok就是false     //if !ok {     //      //結(jié)束循環(huán)     //      break     //}     //fmt.Println(i)     //}     //方式二取值     for i:=range ch{         fmt.Println(i) } }

執(zhí)行結(jié)果

報(bào)錯(cuò)是因?yàn)槲以趍ain中完成了發(fā)送值和取值兩個(gè)操作，所以會出現(xiàn)上述問題，但是結(jié)果是沒有錯(cuò)的。

單向通道

我們知道通道是可以發(fā)送值和取值的，但是某些場景為了安全起見，理論來說只能取值，后者只能發(fā)送值。

單向通道通常只在函數(shù)參數(shù)中體現(xiàn)。

• 形參 chan<- chan類型只寫。

• 形參 <-chan chan類型只讀。

修改上述快遞員代碼。

package main  import (     "fmt"     "sync" )  var wg sync.WaitGroup  //快遞員，快遞員放10個(gè)快遞，只寫 chan<- string func 快遞員(kuaidigui chan<- string) {     defer wg.Done()     for i := 0; i < 10; i++ {         fmt.Println("快遞員放入了第"， i， "快遞")         kuaidigui <- fmt.Sprintf("第%d個(gè)快遞"， i) }     //放完快遞就關(guān)閉了通道     close(kuaidigui) }  //張三，拿走3個(gè)快遞，只讀<-chan string func 張三(kuaidigui <-chan string) {     defer wg.Done()     for i := 0; i < 3; i++ {         fmt.Println("張三拿走" + <-kuaidigui) } }  //李四拿走7個(gè)快遞 func 李四(kuaidigui <-chan string) {     defer wg.Done()     for i := 0; i < 7; i++ {         fmt.Println("李四拿走" + <-kuaidigui) } } func main() {     //快遞柜，10個(gè)大小     var 快遞柜 = make(chan string， 10)     wg.Add(3)     go 快遞員(快遞柜)     go 張三(快遞柜)     go 李四(快遞柜)     wg.Wait() }

總結(jié)

上述講述了Go語言并發(fā)如何和channel配合使用，畢竟我們一般的任務(wù)都不是單獨(dú)運(yùn)行的，都是互相配合的。

感謝各位的閱讀，以上就是“Go語言基礎(chǔ)并發(fā)channel”的內(nèi)容了，經(jīng)過本文的學(xué)習(xí)后，相信大家對Go語言基礎(chǔ)并發(fā)channel這一問題有了更深刻的體會，具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是億速云，小編將為大家推送更多相關(guān)知識點(diǎn)的文章，歡迎關(guān)注！