在Go語言中，可以使用goroutine和channel來實現并發處理同樣的數據。下面是一個簡單的示例：
package main
import (
"fmt"
"sync"
)
func processData(data int, wg *sync.WaitGroup, resultChan chan int) {
defer wg.Done()
// 在這里進行數據處理的邏輯，這里簡單地將數據乘以2
result := data * 2
// 將處理結果發送到結果通道
resultChan <- result
}
func main() {
// 創建一個等待組和結果通道
var wg sync.WaitGroup
resultChan := make(chan int)
data := []int{1, 2, 3, 4, 5}
// 啟動goroutine并發處理數據
for _, d := range data {
wg.Add(1)
go processData(d, &wg, resultChan)
}
// 等待所有goroutine完成
go func() {
wg.Wait()
close(resultChan)
}()
// 從結果通道中讀取處理結果
for result := range resultChan {
fmt.Println(result)
}
}
在上面的示例中，首先創建了一個等待組和一個結果通道。然后，使用go關鍵字啟動多個goroutine并發處理數據。每個goroutine都會調用processData函數進行數據處理，并將處理結果發送到結果通道。在主函數中，通過啟動一個匿名goroutine來等待所有的goroutine完成，并關閉結果通道。最后，通過range resultChan循環來讀取結果通道中的處理結果并輸出。
