Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

Thread-safe operation with Stdout and Stderr (exec. Cmd)

Tags:

stdout

go

I have code and it works in the correct way, but it isn’t thread-safety https://play.golang.org/p/8EY3i1Uk_aO in these rows race happens here.

stdout := cmd.Stdout.(*bytes.Buffer).String()
stderr := cmd.Stderr.(*bytes.Buffer).String()

I rewrote it in this way

readout, _ := cmd.StdoutPipe()
readerr, _ := cmd.StderrPipe()

The link https://play.golang.org/p/htbn2zXXeQk

I don’t like that MultiReader is used here and I cannot separate data stdout from stderr

r, _ := bufio.NewReader(io.MultiReader(readout, readerr)).ReadString('\n')

Also the second example doesn’t work (it is commented in the code). I expected stdout not to be empty (like here https://play.golang.org/p/8EY3i1Uk_aO)

How to make the logic like in the first example, but it should be thread-safety?


1 Answers

You have to pump cmd.Stdout and cmd.Stderr in separate goroutines until they are closed, for example, like you did with cmd.Stdin (but in other direction, of course). Otherwise there's a risk of deadlock - the process is blocked waiting to write to stdout/stderr, and your program is blocked waiting for the process to finish.

Or, like @JimB said, just assign string buffers to cmd.Stdout and cmd.Stderr, they will be filled as the process runs.

func invoke(cmd *exec.Cmd) (stdout string, stderr string, err error) {
    stdoutbuf, stderrbuf := new(strings.Builder), new(strings.Builder)
    cmd.Stdout = stdoutbuf
    cmd.Stderr = stderrbuf
    err = cmd.Start()
    if err != nil {
        return
    }
    err = cmd.Wait()
    return stdoutbuf.String(), stderrbuf.String(), err
}

Live demo:

https://play.golang.org/p/hakSVNbqirB

like image 116
rustyx Avatar answered Oct 19 '25 00:10

rustyx



Donate For Us

If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!