Golang併發一招掌握無阻塞通道讀寫

介紹golang併發的模型寫了幾篇了，但一直沒有以channel為主題進行介紹，今天就給大家聊一聊channel，channel的基本使用非常簡單，想必大家都已了解，所以直接來個高階點的：介紹channel的阻塞情況，以及給你乙個必殺技，立馬解決阻塞問題，實用性高。

無論是有快取通道、無緩衝通道都存在阻塞的情況。阻塞場景共4個，有快取和無緩衝各2個。

無緩衝通道的特點是，傳送的資料需要被讀取後，傳送才會完成，它阻塞場景：

通道中無資料，但執行讀通道。

通道中無資料，向通道寫資料，但無協程讀取。

// 場景1
func readnodatafromnobufch() 
// 場景2
func writenobufch()

注：示例**中的output注釋代表函式的執行結果，每乙個函式都由於阻塞在通道操作而無法繼續向下執行，最後報了死鎖錯誤。

有快取通道的特點是，有快取時可以向通道中寫入資料後直接返回，快取中有資料時可以從通道中讀到資料直接返回，這時有快取通道是不會阻塞的，它阻塞場景是：

通道的快取無資料，但執行讀通道。

通道的快取已經佔滿，向通道寫資料，但無協程讀。

// 場景1
func readnodatafrombufch() 
// 場景2
func writebufchbutfull()

golang併發模型：輕鬆入門select

golang併發模型：select高階

下面示例**是使用select修改後的無緩衝通道和有緩衝通道的讀寫，以下函式可以直接通過main函式呼叫，其中的ouput的注釋是執行結果，從結果能看出，在通道不可讀或者不可寫的時候，不再阻塞等待，而是直接返回。

// 無緩衝通道讀
func readnodatafromnobufchwithselect()  else 
// output:
// channel has no data
}// 有緩衝通道讀
func readnodatafrombufchwithselect()  else 
// output:
// channel has no data
}// select結構實現通道讀
func readwithselect(ch chan int) (x int, err error) 
}// 無緩衝通道寫
func writenobufchwithselect()  else 
// output:
// channel blocked, can not write
}// 有緩衝通道寫
func writebufchbutfullwithselect()  else 
// output:
// channel blocked, can not write
}// select結構實現通道寫
func writechwithselect(ch chan int) error 
}

使用default實現的無阻塞通道阻塞有乙個缺陷：當通道不可讀或寫的時候，會即可返回。實際場景，更多的需求是，我們希望嘗試讀一會資料，或者嘗試寫一會資料，如果實在沒法讀寫再返回，程式繼續做其它的事情。

使用定時器替代default可以解決這個問題，給通道增加讀寫資料的容忍時間，如果500ms內無法讀寫，就即刻返回。示例**修改一下會是這樣：

func readwithselect(ch chan int) (x int, err error) 
}func writechwithselect(ch chan int) error 
}

結果就會變成超時返回：

read time out write time out read time out

write time out

本文所有示例原始碼，及歷史文章、**都儲存在github：

使用select的default語句，在channel不可讀寫時，即可返回

使用select+定時器，在超時時間內，channel不可讀寫，則返回

希望這篇文章對你的channel讀寫有所啟發。

Golang併發一招掌握無阻塞通道讀寫

一招教你無阻塞讀寫Golang channel

每日一招熟練掌握變盤方向

輕鬆一招搞定微信朋友圈推廣

Golang併發 一招掌握無阻塞通道讀寫

一招教你無阻塞讀寫Golang channel

每日一招 熟練掌握變盤方向

輕鬆一招 搞定微信朋友圈推廣

相關推薦

Golang併發一招掌握無阻塞通道讀寫

每日一招熟練掌握變盤方向

輕鬆一招搞定微信朋友圈推廣