正确地将stdin上的数据传递给命令，并在golang中从该命令的stdout接收数据

Question

我有以下程序：package mainimport "bytes"import "io"import "log"import "os"import "os/exec"import "time"func main() {    runCatFromStdinWorks(populateStdin("aaa\n"))    runCatFromStdinWorks(populateStdin("bbb\n"))}func populateStdin(str string) func(io.WriteCloser) {    return func(stdin io.WriteCloser) {        defer stdin.Close()        io.Copy(stdin, bytes.NewBufferString(str))    }}func runCatFromStdinWorks(populate_stdin_func func(io.WriteCloser)) {    cmd := exec.Command("cat")    stdin, err := cmd.StdinPipe()    if err != nil {        log.Panic(err)    }    stdout, err := cmd.StdoutPipe()    if err != nil {        log.Panic(err)    }    err = cmd.Start()    if err != nil {        log.Panic(err)    }    go populate_stdin_func(stdin)    go func() {            // Removing the following lines allow some output            // to be fetched from cat's stdout sometimes            time.Sleep(5 * time.Second)            io.Copy(os.Stdout, stdout)    }()    err = cmd.Wait()    if err != nil {        log.Panic(err)    }}循环运行时，没有任何结果，如下所示：$ while true; do go run cat_thingy.go; echo ; done^C这个结果是在虚拟机中从 apt 在 Ubuntu 12.04 上安装 golang-go 之后（go 版本 go1）。我无法在Macbook Air（执行版本go1.0.3）上的执行安装中复制。这似乎是某种比赛条件。实际上，如果我放置一个sleep（1 * time.Second），那么我永远也看不到这个问题，而我的代码却以随机休眠为代价。我在代码中做错什么了吗，或者这是一个错误？如果是错误，是否已解决？

Answer 1

转到语句

“ go”语句作为一个独立的并发控制线程或goroutine在同一地址空间内开始执行函数或方法调用。

GoStmt =“ go”表达式。

表达式必须是一个调用。函数值和参数在调用goroutine中照常进行评估，但是与常规调用不同，程序执行不等待被调用函数完成。取而代之的是，该函数开始在新的goroutine中独立执行。当函数终止时，其goroutine也终止。如果函数具有任何返回值，则在函数完成时将其丢弃。

将免费的goroutine转换为函数调用。

package main

import (

    "bytes"

    "io"

    "log"

    "os"

    "os/exec"

)

func main() {

    runCatFromStdinWorks(populateStdin("aaa\n"))

    runCatFromStdinWorks(populateStdin("bbb\n"))

}

func populateStdin(str string) func(io.WriteCloser) {

    return func(stdin io.WriteCloser) {

        defer stdin.Close()

        io.Copy(stdin, bytes.NewBufferString(str))

    }

}

func runCatFromStdinWorks(populate_stdin_func func(io.WriteCloser)) {

    cmd := exec.Command("cat")

    stdin, err := cmd.StdinPipe()

    if err != nil {

        log.Panic(err)

    }

    stdout, err := cmd.StdoutPipe()

    if err != nil {

        log.Panic(err)

    }

    err = cmd.Start()

    if err != nil {

        log.Panic(err)

    }

    populate_stdin_func(stdin)

    io.Copy(os.Stdout, stdout)

    err = cmd.Wait()

    if err != nil {

        log.Panic(err)

    }

}