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