Go語言使用goroutine及通道實現並發詳解
使用通道接收數據
在上一篇文章中介紹瞭通道以及使用通道發送數據,本篇接著瞭解通道的基本內容,如何使用通道接收數據;
通道的接收同樣使用"<-"操作符;
使用通道接收數據的特性如下:
- 通道的發送和接收操作在不同的兩個goroutine間進行,由於通道中的數據在沒有接收方接收時會持續阻塞,所以通道的接收必定在另外一個goroutine中進行;
- 如果在接收方接收時,通道中沒有發送方發送數據,則接收方也會發生阻塞,直到發送方發送消息為止;
- 通道一次隻能接收一個元素數據;
通道的數據接收有四種寫法,接下來一一進行介紹
阻塞接收數據
阻塞模式在接收數據時,將接收變量作為"<-"操作符的左值,格式如下:
data := <-ch
執行該語句時將會阻塞,直到接收到數據並賦值給data變量
非阻塞接收數據
在使用非阻塞方式從通道接收數據時,語句不會發生阻塞,格式如下
data, ok := <-ch
data:接收到的數據,在未接收到數據時data為通道類型的零值
ok:是否接收到數據
非阻塞的通道接收方法,可能造成高的CPU占用,因此使用非常少,如果需要實現接收超時檢測,則需要配合select和計時器進行;
接收任意數據,忽略掉接收的數據
寫法如下:
<-ch
使用上面的這種寫法,會發生阻塞,直到接收到消息,但是通道在接收到數據後會將其忽略掉;這個方式實際上隻是通過通道在goroutine間阻塞收發,從而實現並發同步;
使用通道做並發同步的示例如下圖所示:
循環接收數據
通道的數據接收可以借用for-range語句進行多個元素的接收操作,格式如下:
for data := range ch{ }
通道ch是可以被遍歷的,遍歷的結果就是接收到的數據,數據類型就是通道的數據類型,通過for遍歷獲得的變量隻有一個,即上面例子中的data;
遍歷通道數據的示例如下圖所示:
通道可以在兩個goroutine之間通過傳遞一個指定類型的值來同步運行和通訊,操作符"<-"用於指定通道的方向、發送和接收,如果未指定方向,則為雙向通道;
ch <- v 把v發送到通道ch中
v := <-ch 從ch接收數據,並把值賦給v
下面列舉一個示例通過兩個goroutine計算數字之和,如下圖所示:
以上就是通道接收數據的相關內容,更多關於Go goroutine通道並發的資料請關註WalkonNet其它相關文章!
推薦閱讀:
- Go語言CSP並發模型實現MPG
- Go語言如何輕松編寫高效可靠的並發程序
- Go並發的方法之goroutine模型與調度策略
- Python中range函數的基本用法完全解讀
- Go語言context上下文管理的使用