golangでタスクを同期的に実行する方法

Goではgoroutineとチャネルを使用して、タスクの並行実行を実現できます。手順は次のとおりです。

1. タスク間の通信を行うチャンネルを作成します。
2. goroutine内でタスクを実行し、結果をチャンネルに送信する。
3. メインゴリューチンで、すべてのタスクが完了するまでチャネルから結果を受信する。

サンプルコードを以下に示します。

package main

import "fmt"

func worker(id int, jobs <-chan int, results chan<- int) {
    for j := range jobs {
        // 执行任务
        fmt.Println("worker", id, "started job", j)
        // 模拟任务耗时
        for i := 0; i < 100000000; i++ {
        }
        fmt.Println("worker", id, "finished job", j)
        // 将结果发送到通道中
        results <- j * 2
    }
}

func main() {
    // 创建任务通道和结果通道
    jobs := make(chan int, 5)
    results := make(chan int, 5)

    // 启动3个goroutine执行任务
    for w := 1; w <= 3; w++ {
        go worker(w, jobs, results)
    }

    // 发送5个任务到任务通道中
    for j := 1; j <= 5; j++ {
        jobs <- j
    }
    close(jobs) // 关闭任务通道，表示任务已经发送完毕

    // 从结果通道中读取结果，直到所有任务都完成
    for a := 1; a <= 5; a++ {
        <-results
    }
}

上記の例では、5つのバッファを備えたタスクチャネルと5つのバッファを備えた結果チャネルを作成しました。次に、3つのgoroutineを開始してタスクを実行し、タスクチャネルを介してそれらのタスクをそれらに分散します。各goroutineは、タスクの実行後に結果を結果チャネルに送信します。

メインゴリューチンで、5つのタスクをタスクチャネルに送り、チャネルを閉じてタスクの送信が終了したことを示します。次に、すべてのタスクが完了するまで結果チャネルから結果を読み取ります。

かくしてタスクの同期実行が実現した。