猿问

来自其他程序的流标准输出,不带for循环

我有一个程序可以编译并运行另一个程序,然后将stdout传递到自身进行打印,因为该程序不会终止,所以我需要流式传输它的stdout


// boilerplate ommited


func stream(stdoutPipe io.ReadCloser) {

    buffer := make([]byte, 100, 1000)

    for ;; {

        n, err := stdoutPipe.Read(buffer)

        if err == io.EOF {

            stdoutPipe.Close()

            break

        }

        buffer = buffer[0:n]

        os.Stdout.Write(buffer)

    }

}


func main() {

    command := exec.Command("go", "run", "my-program.go")

    stdoutPipe, _ := command.StdoutPipe()


    _ = command.Start()


    go stream(stdoutPipe)


    do_my_own_thing()


    command.Wait()

}

它可以工作,但是如何在不使用for循环反复检查的情况下执行相同的操作,是否有一个库函数可以执行相同的操作?


墨色风雨
浏览 160回答 1
1回答

千巷猫影

您可以将exec.Cmdanio.Writer用作标准输出。您自己的程序用于stdout(os.Stdout)的变量也是一个io.Writer。command := exec.Command("go", "run", "my-program.go")command.Stdout = os.Stdoutcommand.Start()command.Wait()
随时随地看视频慕课网APP

相关分类

Go
我要回答