Go 扫描缓冲区有时会挂起

Question

我使用以下代码，工作正常，但在某些情况下，进程卡住，我看不到任何输出。例如，此代码运行 npm install 或 mvn clean install 并且大多数时候它运行良好，但有时它会挂起并且您没有得到任何输出

func exec(stdout io.Reader, stderr io.Reader) (*bufio.Scanner, *bufio.Scanner) {
    scanout := bufio.NewScanner(stdout)
    scanerr := bufio.NewScanner(stderr)

    scanout.Split(bufio.ScanRunes)
    for scanout.Scan() {
        fmt.Print(scanout.Text())
    }

    scanerr.Split(bufio.ScanRunes)
    for scanerr.Scan() {
        fmt.Print(scanerr.Text())
    }
    return scanout, scanerr
}

现在，如果我更改如下顺序(首先是错误，第二是标准输出)，当命令挂起时，我会收到一些错误输出，但是我看不到在线输出，当您运行命令时，您会看到一些输出，当完成时剩下的你都看到了。您可以等待输出 2 分钟或更长时间，并在过程结束时立即获得长输出。

如何修复我能够在线获取输出并在进程挂起时获得一些反馈？

func exec(stdout io.Reader, stderr io.Reader) (*bufio.Scanner, *bufio.Scanner) {
    scanout := bufio.NewScanner(stdout)
    scanerr := bufio.NewScanner(stderr)

    scanout.Split(bufio.ScanRunes)
    for scanout.Scan() {
        fmt.Print(scanout.Text())
    }
    scanerr.Split(bufio.ScanRunes)
    for scanerr.Scan() {
        fmt.Print(scanerr.Text())
    }


    }
    return scanout, scanerr
}

更新

应该是这样吗？

func exec(stdout io.Reader, stderr io.Reader) (*bufio.Scanner, *bufio.Scanner) {

scanout := bufio.NewScanner(stdout)
scanout.Split(bufio.ScanRunes)
go func() {
    for scanout.Scan() {
        fmt.Print(scanout.Text())
     }
}()

go func() {
scanerr.Split(bufio.ScanRunes)
        for scanerr.Scan() {
            fmt.Print(scanerr.Text())
        }
}()

}

Answer 1

在第一种情况下，您将从进程的标准输出中读取数据，直到进程结束。然后你从 stderr 中读取。在第二种情况下，您首先读取 err，然后读取 out。你应该阅读他们的文章。要么使用 Cmd.CombinedOutput 这将返回它们，要么启动两个 goroutine，一个从 stdin 读取，一个从 stderr 读取，直到流关闭。

scanout := bufio.NewScanner(stdout)
scanout.Split(bufio.ScanRunes)
go func() {
    for scanout.Scan() {
        fmt.Print(scanout.Text())
     }
}()