sync.WaitGroupを使用せずにデッドロックを防ぐ方法は？

Question

concurrent.go：

package main 

import (
    "fmt" 
    "sync" 
) 

// JOBS represents the number of jobs workers do 
const JOBS = 2 

// WORKERS represents the number of workers 
const WORKERS = 5 

func work(in <-chan int, out chan<- int, wg *sync.WaitGroup) { 
    for n := range in { 
     out <- n * n 
    } 
    wg.Done() 
} 

var wg sync.WaitGroup 

func main() { 
    in := make(chan int, JOBS) 
    out := make(chan int, JOBS) 

    for w := 1; w <= WORKERS; w++ { 
     wg.Add(1) 
     go work(in, out, &wg) 
    } 

    for j := 1; j <= JOBS; j++ { 
     in <- j 
    } 
    close(in) 

    wg.Wait() 
    close(out) 
    for r := range out { 
     fmt.Println("result:", r) 
    } 

    // This is a solution but I want to do it with `range out` 
    // and also without WaitGroups 
    // for r := 1; r <= JOBS; r++ { 
    // fmt.Println("result:", <-out) 
    // } 
} 

例goplayにhereです。

Answer 1

これはwaitgroupなしの同期の例です。

Example in the Go playground

package main 

import (
    "fmt" 
) 

// number of jobs workers do 
const JOBS = 10 

// number of workers 
const WORKERS = 2 

func work(in <-chan int, out chan<- int, done chan<- bool) { 
    for n := range in { 
     out <- n * n 
    } 
    done <- true 
} 

func main() { 
    in := make(chan int, JOBS) 
    out := make(chan int, JOBS) 
    done := make(chan bool, WORKERS) 

    // launch workers 
    for w := 1; w <= WORKERS; w++ { 
     go work(in, out, done) 
    } 

    // give jobs to workers 
    for j := 1; j <= JOBS; j++ { 
     in <- j 
    } 
    close(in) 

    // list the results 
    go func() { 
     i := 0 
     for r := range out { 
      fmt.Println("result:", r) 

      // when all jobs completed mark as done 
      i++ 
      if i == JOBS { 
       done <- true 
      } 
     } 
    }() 

    // wait for all goroutines to keep up 
    // WORKERS + RESULT go routines 
    for i := 0; i < WORKERS + 1; i++ { 
     <- done 
    } 

    // prevent leaking chans 
    close(out) 
} 

Answer 2

ゴルーチンは、並行して独立して実行されます。 Spec: Go statements:

「行く」の文は、同じアドレス空間内で、制御の独立した同時スレッドとして関数呼び出しの実行を開始、またはゴルーチン。

あなたはoutチャンネルから値を受け取るためにfor rangeを使用したい場合は、それがoutチャンネルのみすべてのゴルーチンがそれに送信完了したら閉じることができることを意味します。

goroutineは同期して独立して実行されるため、同期することはできません。

WaitGroupを使用することは、それを行うための1つの方法です（outを閉じる前にすべてのゴルーチンが作業を完了するのを確実にするためです）。

あなたのコメント付きコードは別の方法です。コメント付きコードは、ゴルーチンが送信しなければならないチャンネルと同じ数のチャンネルを受信します。これは、すべてのゴルーチンが値を送信する場合にのみ可能です。同期はsend文とreceive操作です。

注

通常チャネルからの結果を受信し、専用ゴルーチンに、非同期的に行われ、あるいは複数のゴルーチンを使用しています。そうすることで、すべての結果をバッファできるバッファでチャネルを使用する必要はありません。すべてのワーカーが仕事を終えるのを待つためにはまだ同期が必要ですが、ゴルティンのスケジューリングと実行が同時に独立しているため、これを避けることはできません。