Go - выполнить Bash Command п раз, используя goroutines и магазин и распечатать свой результат

Question

Я довольно новыми для Golang в целом, и я пытаюсь выполнить bash command with its arguments n times, то хранить Output в переменной и Print его.

Я могу сделать это только один раз, или просто используя loops как следующее:

package main 

import (
    "fmt" 
    "os/exec" 
    "os" 
    "sync" 
) 


func main() { 

    //Default Output 
    var (
     cmdOut []byte 
     err error 
    ) 

    //Bash Command 
    cmd := "./myCmd" 
    //Arguments to get passed to the command 
    args := []string{"arg1", "arg2", "arg3"} 

    //Execute the Command 
    if cmdOut, err = exec.Command(cmd, args...).Output(); err != nil { 
     fmt.Fprintln(os.Stderr, "There was an error running "+cmd+" "+args[0]+args[1]+args[2], err) 
     os.Exit(1) 
    } 
    //Store it 
    sha := string(cmdOut) 
    //Print it 
    fmt.Println(sha) 
} 

Это прекрасно работает, я могу читать output легко.

Теперь, я хотел бы повторить эту же операцию для n раз, используя goroutines.

Я пробовал следовать тому же подходу парня, который ответил How would you define a pool of goroutines to be executed at once in Golang?, но я не могу заставить его работать.

Вот что я пытался до сих пор:

package main 

import (
    "fmt" 
    "os/exec" 
    "sync" 
) 


func main() { 

    //Bash Command 
    cmd := "./myCmd" 
    //Arguments to get passed to the command 
    args := []string{"arg1", "arg2", "arg3"} 

    //Common Channel for the goroutines 
    tasks := make(chan *exec.Cmd, 64) 

    //Spawning 4 goroutines 
    var wg sync.WaitGroup 
    for i := 0; i < 4; i++ { 
     wg.Add(1) 
     go func() { 
      for cmd := range tasks { 
       cmd.Run() 
      } 
      wg.Done() 
     }() 
    } 

    //Generate Tasks 
    for i := 0; i < 10; i++ { 
     tasks <- exec.Command(cmd, args...) 
     //Here I should somehow print the result of the latter command 
    } 
    close(tasks) 

    // wait for the workers to finish 
    wg.Wait() 

    fmt.Println("Done") 

} 

Но я на самом деле не узнать, как хранить i-result казненного команды и распечатать его.

Как я могу это достичь?

Заранее благодарим за любые разъяснения по вопросу, просто оставляйте комментарий.

Answer 1

поэтому следующие исправления вашей проблемы

• можно назвать Cmd.Output(), чтобы получить вывод команды. , иначе вы могли бы подключить трубу Cmd.StdOutPipe к байту. Буффер для примера и прочитать из этого.

• Ваша логика goroutine была неправильной. он будет выполняться только в 4 раза, а затем waitgroup будет Done(), и main выйдет. Вы правильно закрываете канал из основного, чтобы сигнализировать рабочим о выходе из цикла диапазона. wg.Done следует вызвать после этого, поэтому я отложил его.

• при выполнении анонимных функций с помощью команды go старайтесь не захватывать что-либо из родительской области. это может привести к катастрофе. вместо этого выясните, какие параметры вы хотите, и передайте их функции.

`

package main 

import (
    "fmt" 
    "os/exec" 
    "sync" 
) 
func main() { 
    cmd := "./foo.sh" 
    //Arguments to get passed to the command 
    args := []string{"bar", "baz"} 

    //Common Channel for the goroutines 
    tasks := make(chan *exec.Cmd, 64) 

    //Spawning 4 goroutines 
    var wg sync.WaitGroup 
    for i := 0; i < 4; i++ { 
      wg.Add(1) 
      go func(num int, w *sync.WaitGroup) { 
        defer w.Done() 
        var (
          out []byte 
          err error 
        ) 
        for cmd := range tasks { // this will exit the loop when the channel closes 
          out, err = cmd.Output() 
          if err != nil { 
            fmt.Printf("can't get stdout:", err) 
          } 
          fmt.Printf("goroutine %d command output:%s", num, string(out)) 
        } 
      }(i, &wg) 
    } 
    //Generate Tasks 
    for i := 0; i < 10; i++ { 
      tasks <- exec.Command(cmd, args...) 
    } 
    close(tasks) 

    // wait for the workers to finish 
    wg.Wait() 

    fmt.Println("Done") 

} 

`