goでデータを並列に処理する方法

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キーワードを使って、データを並列に処理します。 各ゴルーチンはprocessData関数を呼び出してデータを処理し、その処理結果を結果チャネルに送信します。 主関数が、匿名のゴルーチンを起動して、全てのゴルーチンが完了するのを待って、結果チャネルを閉じます。 最後に、resultChanの処理結果を読みとって出力します。