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