forループ内の同時ゴルーチン

Question

私はgoroutineをforループ内に以下のように記述しました。私が望むのは、listofDevicesリスト内の各項目のゴルーチンを同時に実行することですが、このロジックはlistofDevicesリスト内の1つの項目についてのみgoroutineを実行しています。

for _, ip := range listOfDevices { 
      inChan <- types.NewNotification(time.Now(), "/cloudtracer/status", nil, 
        &map[key.Key]interface{}{ 
          key.New(ip): types.Pointer{Pointer: "/cloudtracer/status/" + ip}, 
        }) 
      pingOneMachine := probe.NewPing(ip, 2*time.Second, inChan) 
      // For now stopping the probe after few minutes. This will change later 
      ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second) 
      defer cancel() 

      wg.Add(len(listOfDevices)) 
      go func() { 
        defer wg.Done() 
        pingOneMachine.Run(ctx) 
      }() 
    } 
    wg.Wait() 

誰でもこの問題を解決するのに手伝ってもらえますか？ありがとうございます。

それはで使用される前に、 ctx変数名は、forループで上書きされている

  go func(c context.Context) { 
        defer wg.Done() 
        pingOneMachine.Run(c) 
      }(ctx) // pass in the lexically scoped variable here 

：

Answer 1

はゴルーチン閉鎖を使用してみてください

for ;;{ 
     wg.Add(1) 
     go func(){ 
      defer wg.Done() 
     } 
    } 
    wg.Wait() 

Answer 2

を次のようにそれを行いますgoroutine（変数がレキシカルスコープであるため）、この質問を参照してください。Why does Golang handle closures differently in goroutines?

基本的に変数は参照によって渡されます。

これは、「外側」スコープのクロージャ内で参照される変数はすべてコピーではなく、実際には参照であることを意味します。

Answer 3

for ;;{ 
    wg.Add(1) 
    go func(ip string){ 
     defer wg.Done() 
    }(ip) 
} 
wg.Wait() 

それはすべてのIPアドレスに対して並列ゴルーチンの作成で働いていました。