管道是 golang 中一種特殊類型,用于 goroutine 之間安全高效的通信,特別適用于并行處理和數據交換。使用 make(chan t) 創建管道,其中 t 是傳遞數據類型;通過
Golang 管道:并行處理函數通信的機制
管道在 Golang 中是一種特殊的類型,允許 Goroutine(并發執行的函數)之間安全且高效地通信。這在并行處理和數據交換的情形中非常有用。
管道語法
創建一個管道使用 make(chan T)
語法,其中 T
是管道中傳遞數據的類型。例如:
myChannel := make(chan int)
登錄后復制
向管道發送數據
使用 <-
運算符從管道中接收數據。例如:
data := <-myChannel
登錄后復制
從管道接收數據
使用 <-
運算符向管道發送數據。例如:
myChannel <- 42
登錄后復制
實戰案例:并行求和
以下示例演示了如何使用管道并行計算切片的總和:
package main import "fmt" func main() { numbers := []int{1, 2, 3, 4, 5, 6, 7, 8, 9, 10} numWorkers := 2 // 創建管道 results := make(chan int) // 創建 Goroutine 并在管道上發送部分和 for i := 0; i < numWorkers; i++ { go func(start, end int) { partialSum := 0 for i := start; i <= end; i++ { partialSum += numbers[i] } results <- partialSum }(i * len(numbers) / numWorkers, (i+1) * len(numbers) / numWorkers - 1) } // 讀取管道并計算總和 totalSum := 0 for i := 0; i < numWorkers; i++ { totalSum += <-results } fmt.Println("Total sum:", totalSum) }
登錄后復制
在這個示例中,results
管道用于在各個 Goroutine 和主 Goroutine 之間傳遞部分和。主 Goroutine 從管道中讀取結果并計算最終總和。該實現有效的將求和任務分解為并行執行的部分,顯著提高了性能。