概念的には、ゴルーチンを使用して（とどのような私のコードと一緒に間違っている）への正しいアプローチがある

Question

私が持っている2質問：

a）は、それは数学の計算のようなもののためにループ内で複数のゴルーチンをスピンアップしても意味がありません結果？

b）なぜ私のコードが機能しないのですか（これは私の最初のゴルーチンの試みです）？私はそれがチャンネルを閉じることと関係があると推測しています。

package main 

import (
    "fmt" 
    "math" 
    "sync" 
) 

func main() { 
    input := [][]int{ 
     []int{10, 9}, 
     []int{5, 2}, 
     []int{4, 9}, 
    } 

    var wg sync.WaitGroup 
    c := make(chan int) 
    for _, val := range input { 
     wg.Add(1) 
     go func(coordinates []int, c chan int) { 
      defer wg.Done() 
      c <- calculateDistance(coordinates[0], coordinates[1]) 
     }(val, c) 
    } 
    distances := []int{} 

    for val := range c { 
     distances = append(distances, val) 
    } 
    wg.Wait() 
    fmt.Println(distances) 
} 

func calculateDistance(x int, y int) int { 
    v := math.Exp2(float64(x)) + math.Exp2(float64(y)) 
    distance := math.Sqrt(v) 
    return int(distance) 
} 

遊び場リンク：チャンネルが閉じられたときにチャネル上https://play.golang.org/p/0iJ9hFnb8R

Answer 1

）はい、複数のCPUがある場合は、複数のgoルーチンをスピンアップしてCPUバインドタスクを実行することができます。また、実際に利益があるかどうかを調べるためにコードをプロファイルすることが非常に重要です。これを行うには、benchmarkフレームワークで構築されたgoを使用することができます。

CPUによって制限されているので、同期をとるのが良いスタートになる可能性があり、入力リストの項目数ではなくCPUコアの数にゴルーチンをバインドすることができます見る。 Goは、ベンチマークとpprofを使用して、最も効率的なアプローチが何であるかを経験的に判断します。

b）https://play.golang.org/p/zGEQGC9EIyチャンネルは決して終了せず、メインスレッドは終了しません。この例では、すべてのgoルーチンが作業を終了してからチャネルを閉じるまで待機しています。

Answer 2

範囲ループが終了します。あなたがあなたのプログラムで決してチャンネルを閉じることはないので、メインのゴルーチンは最終的に永遠にブロックされ、cから受信しようとします。

Does it make sense to spin up multiple goroutines in a loop for something like calculating a math result?

に依存します。あなたがまだそれを見ていない場合、私はロブパイクの話Concurrency is not parallelismをお勧めできます。これは、どこに有益であるか、どこにないかについての直感を与えるかもしれません。