Golang에서 데이터 샤딩 및 병렬 처리를 위해 채널 사용

package main

import "fmt"

func main() {
    // 创建一个切片，用于存储待处理的数据
    data := []int{1, 2, 3, 4, 5, 6, 7, 8, 9, 10}

    // 创建一个通道，用于接收处理结果
    result := make(chan int)

    // 计算每个数据块的大小
    blockSize := len(data) / 5

    // 通过循环创建 5 个 Goroutine 进行并行计算
    for i := 0; i < 5; i++ {
        // 获取当前数据块的起始位置和结束位置
        start := i * blockSize
        end := (i + 1) * blockSize

        // 创建 Goroutine，并将数据块和结果通道作为参数传递给 Goroutine
        go process(data[start:end], result)
    }

    // 获取结果通道中的计算结果并打印
    for i := 0; i < 5; i++ {
        fmt.Println(<-result)
    }
}

// 处理函数，对数据块进行计算并将结果发送到结果通道中
func process(data []int, result chan int) {
    sum := 0
    for _, num := range data {
        sum += num
    }
    result <- sum
}

15
35
10
45
55