Golang實現(xiàn)Directional Channel(定向通道)
通道可以是定向的( directional )。在默認(rèn)情況下，通道將以雙向的( bidirectional )形式運作，用戶既可以把值放人通道，也可以從通道取出值;但是，通道也可以被限制為只能執(zhí)行發(fā)送操作( send-only )或者只能執(zhí)行接收操作( receive-only )。
通?？梢越?定向通道 ，也有人叫 單向通道 ，兩者其實都是指向這篇短文要討論的 Directional Channel 。
下面直接舉例子說明：
package onlyChannelTest
import (
"fmt"
"math/rand"
"sync"
"testing"
"time"
)
func TestOnlyChannel(t *testing.T) {
var wg sync.WaitGroup
wg.Add(2)
c:= make(chan int, 3)
var send chan<- int = c
var recv <-chan int = c
go func() {
defer wg.Done()
for i := 0; i < 6; i++ { // 注意這里是 6
fmt.Print("receive\n")
fmt.Println(<-recv)
}
}()
go func() {
defer wg.Done()
defer close(c)
rand.Seed(time.Now().UTC().UnixNano())
for i := 0; i < 3; i++ { // 這里是 3
fmt.Print("send\n")
send <- rand.Intn(100)
}
}()
wg.Wait()
}
這里可以先猜一下運行結(jié)果，我直接貼出：
后面的引起了我的注意：
receive
0
是最讓我困惑的地方，因為在一般印象內(nèi) channel 都是會阻塞的存在，而從上面結(jié)果看，第一個 recv 也是阻塞了）。但是后面的的 recv 卻沒有起到阻塞的作用，還是把 c 中的默認(rèn)值 0 輸出了。
通過 debug ，不難看出的是，兩個單向通道的發(fā)送和接收都是從一個緩沖通道中進行操作的，兩個單項通道同屬于一個雙向通道，只不過他們被分別限制了接收和發(fā)送功能。
通過 debug ，再次發(fā)現(xiàn)，在 recv 讀取完之后，通道內(nèi)并沒有被 “清空” ，而是保有默認(rèn)值。
難道， recv 并沒有被阻塞？
驗證方法如下：
// defer close(c)
選擇注釋掉發(fā)送 Goroutine 中的關(guān)閉通道。
結(jié)果很明顯，造成死鎖，證明兩個單向通道之間是有通信的，有阻塞的。
最后通過源碼，還是找到了答案：
由此，為避免接收到不需要的無效 零值 ，應(yīng)修改接收 Goroutine -- receive 的寫法：
go func() {
defer wg.Done()
for i := 0; i < 6; i++ { // 注意這里是 6
x, ok := <-recv
if ok {
fmt.Print("receive\n")
fmt.Println(x)
}else{
break
}
}
}()
到此這篇關(guān)于Golang實現(xiàn)Directional Channel(定向通道)的文章就介紹到這了,更多相關(guān)Golang定向通道內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
Golang實現(xiàn)自定義時間結(jié)構(gòu)體并支持Json&Gorm
因為時區(qū)等問題,很多項目需要自定義時區(qū)和時間格式,所以這篇文章主要為大家介紹了Golang如何實現(xiàn)自定義時間結(jié)構(gòu)體并支持Json&Gorm,希望對大家有所幫助2024-03-03
Go 并發(fā)編程Goroutine的實現(xiàn)示例
Go語言中的并發(fā)編程主要通過Goroutine和Channel來實現(xiàn),本文就來介紹一下Go 并發(fā)編程的實現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2024-12-12
Golang處理gRPC請求/響應(yīng)元數(shù)據(jù)的示例代碼
前段時間實現(xiàn)內(nèi)部gRPC框架時,為了實現(xiàn)在服務(wù)端攔截器中打印請求及響應(yīng)的頭部信息,便查閱了部分關(guān)于元數(shù)據(jù)的資料,因為中文網(wǎng)絡(luò)上對于該領(lǐng)域的信息較少,于是在這做了一些簡單的總結(jié),需要的朋友可以參考下2024-03-03
這篇文章主要介紹了Go語言中如何通過方法為類型添加行為的相關(guān)資料，文中通過圖文介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-09-09
Map是一個強大而又有趣的工具，它可以幫助我們高效地存儲和操作鍵值對數(shù)據(jù)，本文主要介紹了Go語言中Map的各種操作，包括增加、查找、刪除、遍歷等，具有一定的參考價值，感興趣的可以了解一下2023-08-08
這篇文章主要介紹了Go批量操作excel導(dǎo)入到mongo,包括選擇命令行包，讀取配置連接數(shù)據(jù)庫的方法，本文示例代碼相結(jié)合給大家介紹的非常詳細(xì)，需要的朋友可以參考下2022-03-03
這篇文章主要給大家介紹了關(guān)于golang中定時器cpu使用率高的現(xiàn)象的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧。2018-04-04
這篇文章主要介紹了go語言中使用timer的常用方式,實例分析了三種常用的使用timer的方法,具有一定參考借鑒價值,需要的朋友可以參考下2015-03-03
Go 通過結(jié)構(gòu)struct實現(xiàn)接口interface的問題
這篇文章主要介紹了Go 通過結(jié)構(gòu)struct實現(xiàn)接口interface的問題,本文通過示例代碼給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2021-10-10
MinIO 是一款基于 Go 語言的高性能、可擴展、云原生支持、操作簡單、開源的分布式對象存儲產(chǎn)品,這篇文章主要介紹了minio分布式文件存儲,需要的朋友可以參考下2023-10-10