使用管道在 go 語言中進(jìn)行函數(shù)間通信的模式有兩種：生產(chǎn)者-消費者模式：生產(chǎn)者函數(shù)寫入管道，消費者函數(shù)讀取管道。工作池模式：一個函數(shù)創(chuàng)建工作管道，其他函數(shù)從管道中接收工作并執(zhí)行。
Go 語言中函數(shù)與管道通信的模式
管道是 Go 語言中用于并發(fā)通信的一種有效機(jī)制。管道是一系列元素的緩沖隊列，其中元素可以從管道的一端寫入，再從另一端讀取。在此過程中，管道可以用來在函數(shù)之間同步執(zhí)行和傳遞數(shù)據(jù)。
1. 管道發(fā)送和接收
管道可以被初始化為一個 int 通道，該通道可以保存任意數(shù)量的 int。make 函數(shù)用于創(chuàng)建管道：
numbers := make(chan int)
登錄后復(fù)制
可以在協(xié)程中發(fā)送值到管道中，使用 chan <-：
go func() {
numbers <- 42
close(numbers)
}()
登錄后復(fù)制
可以使用 <-chan 從管道中讀取值：
var num int num = <-numbers
登錄后復(fù)制
close 函數(shù)用于關(guān)閉管道，表示管道中不再寫入數(shù)據(jù)：
close(numbers)
登錄后復(fù)制
2. 緩沖管道
管道可以是無緩沖的，這意味著管道中最多只能保存一個元素。當(dāng)管道滿時，寫操作會被阻塞。可以通過指定第二個參數(shù) bufferSize 來創(chuàng)建緩沖管道：
numbers := make(chan int, 10)
登錄后復(fù)制
現(xiàn)在管道可以保存最多 10 個元素，在緩沖區(qū)填滿之前，寫操作不會被阻塞。
3. 函數(shù)與管道通信的模式
函數(shù)與管道通信有兩種常見模式：
生產(chǎn)者-消費者模式：生產(chǎn)者函數(shù)向管道中寫入值，而消費者函數(shù)從管道中讀取值。例如，一個函數(shù)讀取文件并向管道發(fā)送文件內(nèi)容，另一個函數(shù)從管道接收內(nèi)容并進(jìn)行處理。工作池模式：一個函數(shù)創(chuàng)建工作管道，其他函數(shù)從管道中接收工作并執(zhí)行它們。例如，一個函數(shù)接收請求并將工作添加到管道中，而另一個函數(shù)從管道中獲取請求并處理它們。
4. 實戰(zhàn)案例：生產(chǎn)者-消費者模式
以下是一個簡單的示例，展示了如何在函數(shù)之間使用管道實現(xiàn)生產(chǎn)者-消費者模式：
package main
import (
"fmt"
"sync"
)
func producer(ch chan int) {
for i := 0; i < 10; i++ {
ch <- i
}
close(ch)
}
func consumer(ch chan int, wg *sync.WaitGroup) {
for num := range ch {
fmt.Println(num)
}
wg.Done()
}
func main() {
ch := make(chan int)
var wg sync.WaitGroup
wg.Add(1)
go producer(ch)
go consumer(ch, &wg)
wg.Wait()
}
登錄后復(fù)制
在這個示例中，producer 函數(shù)會將 10 個整數(shù)寫入管道中，然后關(guān)閉管道。consumer 函數(shù)將會從管道中讀取整數(shù)并打印出來。為了確保 consumer 函數(shù)在 producer 函數(shù)完成之前不會退出，使用了 sync.WaitGroup 進(jìn)行同步。
