Golang并发数据聚合实现方法

func aggregateSum(data []int) int {
    chunkSize := len(data) / 4
    resultChan := make(chan int, 4)
for i := 0; i < len(data); i += chunkSize {
    end := i + chunkSize
    if end > len(data) {
        end = len(data)
    }
    go func(subData []int) {
        sum := 0
        for _, v := range subData {
            sum += v
        }
        resultChan <- sum
    }(data[i:end])
}

total := 0
for i := 0; i < 4; i++ {
    total += <-resultChan
}
return total
}

func aggregateWithWaitGroup(data [][]int) int {
    var wg sync.WaitGroup
    resultChan := make(chan int, len(data))
for _, chunk := range data {
    wg.Add(1)
    go func(sub []int) {
        defer wg.Done()
        sum := 0
        for _, v := range sub {
            sum += v
        }
        resultChan <- sum
    }(chunk)
}

go func() {
    wg.Wait()
    close(resultChan)
}()

total := 0
for sum := range resultChan {
    total += sum
}
return total
}

func aggregateWithMutex(data [][]int) int {
    var mu sync.Mutex
    var total int
var wg sync.WaitGroup
for _, chunk := range data {
    wg.Add(1)
    go func(sub []int) {
        defer wg.Done()
        sum := 0
        for _, v := range sub {
            sum += v
        }
        mu.Lock()
        total += sum
        mu.Unlock()
    }(chunk)
}
wg.Wait()
return total
}