前言

在Java中，多線程之間的通信方式有哪些？記得嗎？Java多線程間通信的解決方案有很多種，比如：synchronized。使用鎖來防止資源亂來，一人一個按順序來，要么使用JDK提供的原子對象，那些Atomic關(guān)鍵字開頭的對象，比如：AtomicInteger，這樣可以在多個線程中讀寫值的時候保證是安全的，還有很多其他的方式，在go中，就一種：通道

通道

go的通道我根據(jù)java的理解，它就是用來解決線程之間通信的東西，go里面的關(guān)鍵字叫channels

以下是搜索出來的解釋：

go語言提倡使用通信的方法代替共享內(nèi)存，當一個資源需要在 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

這個語句是個阻塞語句，只有當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)文章！

最新評論