Golang で効率的な同時操作を実装する方法

package main

輸入 （
    「fmt」
    "時間"
)

関数 main() {
    for i := 0; i < 10; i {
        go func(n int) {
            fmt.Printf("ゴルーチン %d
"、n)
        }（私）
    }
    time.Sleep(time.Second)
}

package main

輸入 （
    「fmt」
)

func worker(id int, jobs <-chan int, results chan<- int) {
    ジョブ := 範囲ジョブ {
        fmt.Printf("ワーカー %d がジョブ %d を処理しています
"、ID、ジョブ)
        結果 <- ジョブ * 2
    }
}

関数 main() {
    ジョブ数 := 5
    ジョブ := make(chan int, numJobs)
    結果 := make(chan int, numJobs)

    for i := 1; i <= 3; i {
        go work(私、仕事、結果)
    }

    for i := 1; i <= numJobs; i {
        ジョブ <-i
    }
    閉じる(求人)

    for i := 1; i <= numJobs; i {
        結果 := <-結果
        fmt.Printf("結果 %d
"、 結果）
    }
}

package main

輸入 （
    「fmt」
    「同期」
)

タイプ カウンタ構造体 {
    ミュー同期ミューテックス
    整数の値
}

func (c *Counter) Increment() {
    cμLock()
    defer c.mu.Unlock()
    c.値
}

func (c *Counter) Value() int {
    cμLock()
    defer c.mu.Unlock()
    c.valueを返す
}

関数 main() {
    カウンタ := カウンタ{}

    var wg sync.WaitGroup
    従業員数 := 5
    wg.Add(ワーカー数)

    for i := 0; i < numWorkers; i {
        go func() {
            wg.Done() を延期する
            for j := 0; j < 1000; j {
                counter.Increment()
            }
        }()
    }

    wg.Wait()

    fmt.Printf("カウンタ値: %d
"、counter.Value())
}