golang?channel管道使用示例解析
更新時間：2022年04月14日 14:28:37 作者：Jeff的技術棧
這篇文章主要介紹了golang?channel管道使用示例解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步早日升職加薪
定義channel管道
定義一個channel時，也需要定義發(fā)送到管道的值類型。channel可以使用內置的make()函數來創(chuàng)建：
var ch = make(chan int) //等價于：make(chan Type,0) var ch = make(chan Type,capacity)
channel管道塞值和取值
ch <- 666 //向ch管道塞入666 <- ch // 向ch管道接收值，并丟棄 x := <-ch //向ch管道中接收數據，并復制給x x, ok := <-ch //向ch管道中接收數據，并復制給x,同時檢查通道是否已關閉或者是否為空
當capacity=0時，channel管道是無緩沖阻塞讀寫，
當capacity>0時，channel管道有緩沖，是非阻塞的，直到寫滿capacity個元素才阻塞寫入。
注意：默認情況下，channel接收和發(fā)送數據都是阻塞的，除非另一端已經準備好，這樣就使得goroutine同步變得更加簡單，而不需要顯示的lock。
通過channel管道實現(xiàn)同步，和數據交互
package main
import (
"fmt"
"time"
)
func main() {
//創(chuàng)建channel
ch := make(chan string)
defer fmt.Println("主協(xié)程也結束")
go func() {
defer fmt.Println("子協(xié)程調用完畢")
for i := 0; i < 2; i++ {
fmt.Println("子協(xié)程 i = ", i)
time.Sleep(time.Second)
}
ch <- "我是子協(xié)程，要工作完畢"
}()
str := <-ch //沒有數據前，阻塞
fmt.Println("str = ", str)
}
無緩沖的channel
ch := make(chan int, 0)
package main
import (
"fmt"
"time"
)
func main() {
//創(chuàng)建一個無緩存的channel
ch := make(chan int, 0)
//len(ch)緩沖區(qū)剩余數據個數， cap(ch)緩沖區(qū)大小
fmt.Printf("len(ch) = %d, cap(ch)= %d\n", len(ch), cap(ch))
//新建協(xié)程
go func() {
for i := 0; i < 10000; i++ {
fmt.Printf("子協(xié)程：i = %d\n", i)
ch <- i //往chan寫內容
time.Sleep(1 * time.Second)
}
}()
go func() {
for {
num := <-ch //讀管道中內容，沒有內容前，阻塞
fmt.Println("num = ", num)
}
}()
for {
}
}
有緩沖的channel管道
ch := make(chan int, 3)
package main
import (
"fmt"
"time"
)
func main() {
//創(chuàng)建一個有緩存的channel
ch := make(chan int, 3)
//len(ch)緩沖區(qū)剩余數據個數， cap(ch)緩沖區(qū)大小
fmt.Printf("len(ch) = %d, cap(ch)= %d\n", len(ch), cap(ch))
//新建協(xié)程
go func() {
for i := 0; i < 10; i++ {
ch <- i //往chan寫內容
fmt.Printf("子協(xié)程[%d]: len(ch) = %d, cap(ch)= %d\n", i, len(ch), cap(ch))
}
}()
//延時
time.Sleep(2 * time.Second)
for i := 0; i < 10; i++ {
num := <-ch //讀管道中內容，沒有內容前，阻塞
fmt.Println("num = ", num)
}
}
關閉channel管道
close(ch)
package main
import (
"fmt"
)
func main() {
//創(chuàng)建一個無緩存的channel
ch := make(chan int, 3)
//len(ch)緩沖區(qū)剩余數據個數， cap(ch)緩沖區(qū)大小
fmt.Printf("len(ch) = %d, cap(ch)= %d\n", len(ch), cap(ch))
//新建協(xié)程
go func() {
for i := 0; i < 10000; i++ {
fmt.Printf("子協(xié)程：i = %d\n", i)
ch <- i //往chan寫內容
//time.Sleep(1 * time.Second)
if i >10 {
close(ch)
break
}
}
}()
go func() {
for {
if num, ok := <-ch; ok == true {
fmt.Println("num = ", num)
} else { //管道關閉
break
}
}
}()
for {
}
}
單向channel管道,讀寫分離
chan<- 表示數據進入管道，只寫
<-chan 表示數據從管道出來，只讀
注意：雙向可轉為單向，單向不可轉為雙向
package main
//"fmt"
func main() {
//創(chuàng)建一個channel, 雙向的
ch := make(chan int)
//雙向channel能隱式轉換為單向channel
var writeCh chan<- int = ch //只能寫，不能讀
var readCh <-chan int = ch //只能讀，不能寫
writeCh <- 666 //寫
//<-writeCh //err, invalid operation: <-writeCh (receive from send-only type chan<- int)
<-readCh //讀
//readCh <- 666 //寫， err, invalid operation: readCh <- 666 (send to receive-only type <-chan int)
//單向無法轉換為雙向
//var ch3 chan int = writeCh //cannot use writeCh (type chan<- int) as type chan int in assignment
}
管道消費者生產者模型
package main
import (
"fmt"
)
//此通道只能寫，不能讀
func producer(out chan<- int) {
for i := 0; i < 10; i++ {
out <- i * i //寫入
}
close(out) //關閉
}
//此channel只能讀，不能寫
func consumer(data <-chan int) {
for num := range data {
fmt.Println("num = ", num)
}
}
func main() {
//創(chuàng)建一個雙向通道
ch := make(chan int)
//生產者，生產數字，寫入channel
//新開一個協(xié)程
go producer(ch) //channel傳參，引用傳遞
//消費者，從channel讀取內容，打印
consumer(ch)
}
以上就是golang channel管道的詳細內容，更多關于channel管道的資料請關注腳本之家其它相關文章！
相關文章
這篇文章主要介紹了Go語言里的結構體文法,實例分析了結構體文法的概念及使用技巧,具有一定參考借鑒價值,需要的朋友可以參考下2015-02-02
大家學習和使用?Go?語言時,有一個神奇的概念：零值（zero-values）,所以本文想給大家分享一個關于零值的新提案,目測已經八九不離十了2023-08-08
golang結構化日志log/slog包之LogValuer的用法簡介
這篇文章主要為大家詳細介紹了golang結構化日志log/slog包中 LogValuer 和日志記錄函數的正確包裝方法,感興趣的小伙伴可以跟隨小編一起了解一下2023-10-10
本文為大家介紹了Go習慣用法（多值賦值,短變量聲明和賦值,簡寫模式、多值返回函數、comma,ok 表達式、傳值規(guī)則）的基礎實例,幫大家鞏固扎實Go語言基礎2024-01-01
淺談Golang中創(chuàng)建一個簡單的服務器的方法
這篇文章主要介紹了淺談Golang中創(chuàng)建一個簡單的服務器的方法，golang中的net/http包對網絡的支持非常好，這樣會讓我們比較容易的建立起一個相對簡單的服務器，有一定的參考價值，感興趣的小伙伴們可以參考一下2018-06-06
本文主要介紹了Go語言單向通道的實現(xiàn)，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2023-04-04
利用systemd部署golang項目的實現(xiàn)方法
這篇文章主要介紹了利用systemd部署golang項目的實現(xiàn)方法，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2019-11-11
日常開發(fā)中我們大概率會遇到超時控制的場景,而一個良好的超時控制可以有效的避免一些問題,所以本文就來和大家深入探討一下Go語言中的超時控制吧2023-10-10
這篇文章主要介紹了Golang: 內建容器的用法，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2021-05-05
關于golang中map使用的幾點注意事項總結(強烈推薦!)
map是一種無序的基于key-value的數據結構,Go語言中的map是引用類型,必須初始化才能使用,下面這篇文章主要給大家介紹了關于golang中map使用的幾點注意事項,需要的朋友可以參考下2023-01-01