一文帶你掌握Golang基礎(chǔ)之通道
前言
在Java中,多線程之間的通信方式有哪些?記得嗎?Java多線程間通信的解決方案有很多種,比如:synchronized。使用鎖來防止資源亂來,一人一個按順序來,要么使用JDK提供的原子對象,那些Atomic關(guān)鍵字開頭的對象,比如:AtomicInteger,這樣可以在多個線程中讀寫值的時候保證是安全的,還有很多其他的方式,在go中,就一種:通道
通道
go的通道我根據(jù)java的理解,它就是用來解決線程之間通信的東西,go里面的關(guān)鍵字叫channels
以下是搜索出來的解釋:
go語言提倡使用通信的方法代替共享內(nèi)存,當(dāng)一個資源需要在 goroutine 之間共享時,通道在 goroutine 之間架起了一個管道,并提供了確保同步交換數(shù)據(jù)的機制。聲明通道時,需要指定將要被共享的數(shù)據(jù)的類型??梢酝ㄟ^通道共享內(nèi)置類型、命名類型、結(jié)構(gòu)類型和引用類型的值或者指針。這里通信的方法就是使用通道(channel),如下圖所示:

圖:goroutine 與 channel 的通信
是不是和java的線程安全對象是類似?或者說是隊列?總之你可以按照你自己經(jīng)驗去理解。
如何創(chuàng)建通道
go提供了創(chuàng)建通道的語法:
通道變量名 := make(chan 數(shù)據(jù)類型)
比如,我們可以這樣寫:
// 創(chuàng)建一個int型的通道 ch1 := make(chan int)
還可以創(chuàng)建一個接口類型通道,比如:
ch2 := make(chan interface{})
還能創(chuàng)建一個結(jié)構(gòu)體的通道,比如:
// 創(chuàng)建一個User結(jié)構(gòu)體的通道,這個通道是個指針通道 ch3 := make(chan *User)
向通道發(fā)送數(shù)據(jù)
go向通道發(fā)送數(shù)據(jù)語法非常簡單:
通道變量名 <- 值
我們向上面三個通道名發(fā)送數(shù)據(jù),可以寫成:
// 1. 給ch1通道傳值0
ch1 <- 0
// 2. 給ch2通道傳字符串,實際可以穿任意對象,因為前面聲明了是interface對象
ch2 <- "hello, mars醬"
// 創(chuàng)建一個userInfo結(jié)構(gòu)體并初始化值
userInfo := User{
1, "mars醬",
}
// 3. 發(fā)送一個結(jié)構(gòu)體到通道ch3中
ch3 <- &userInfo
以上代碼是無法運行的,因為go的通道有個規(guī)矩,發(fā)送和接收必須成對出現(xiàn),不信邪的可以驗證一下。
從通道接收數(shù)據(jù)
go從通道中接收數(shù)據(jù)的語法也簡單:
data := <- ch1
這個語句是個阻塞語句,只有當(dāng)data接收到了值,才會執(zhí)行后續(xù)的,非阻塞的這樣寫:
data, ok := <- ch1
data:接收的數(shù)據(jù),如果沒有接收到,data為0。data為0取決于之前make通道的時候,ch1是個int型通道,如果是其他類型,這個data也應(yīng)該是其他類型對象;
ok:boolean類型的值,表示是否接收到數(shù)據(jù)
還有個奇葩的寫法:
<- ch1
這樣寫就表示通道里有啥都與我無關(guān),忽略掉了。
通道的例子
一個倒數(shù)的例子,通過通道去實現(xiàn)一下:
// author: mars醬
func Test_chanTest(t *testing.T) {
// 1. 創(chuàng)建一個通道
ch1 := make(chan int)
// 2. 啟動goroutine并發(fā)
go func() {
// 從5 到 0
for i := 5; i >= 0; i-- {
// 3. 發(fā)送給通道
ch1 <- i
// 發(fā)完后等1秒
time.Sleep(time.Second)
}
}()
// 4. 循環(huán)接收通道數(shù)據(jù)
for data := range ch1 {
fmt.Println(data)
if data == 0 {
break
}
}
}
運行的結(jié)果:

發(fā)射火箭的倒數(shù)計時就是這樣吧~
以上就是一文帶你掌握Golang基礎(chǔ)之通道的詳細內(nèi)容,更多關(guān)于Golang通道的資料請關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
Go語言同步與異步執(zhí)行多個任務(wù)封裝詳解(Runner和RunnerAsync)
這篇文章主要給大家介紹了關(guān)于Go語言同步與異步執(zhí)行多個任務(wù)封裝(Runner和RunnerAsync)的相關(guān)資料,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧。2018-01-01
優(yōu)雅使用GoFrame共享變量Context示例詳解
這篇文章主要為大家介紹了優(yōu)雅使用GoFrame共享變量Context示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2022-06-06
go?mod?tidy報錯:zip:?not?a?valid?zip?file解決辦法
這篇文章主要給大家介紹了關(guān)于go?mod?tidy報錯:zip:?not?a?valid?zip?file的解決辦法,go mod是進行代碼管理,這錯誤是因為本地分支和遠程分支沖突,本文通過代碼介紹的非常詳細,需要的朋友可以參考下2024-01-01
golang?gorm開發(fā)架構(gòu)及寫插件示例
這篇文章主要為大家介紹了golang?gorm開發(fā)架構(gòu)及寫插件的詳細示例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步早日升職加薪2022-04-04

