您发布的代码有效(执行了合理的命令)。
这是用Go语言编写的一个简单的 “长时间运行的任务” ,供您调用和测试您的代码:
func main() { fmt.Println("Child started.") time.Sleep(time.Second*2) fmt.Println("Tick...") time.Sleep(time.Second*2) fmt.Println("Child ended.")}编译它并作为命令来调用它。您将看到子进程“流化”立即显示不同的行。
它可能对您不起作用的原因
在
Scanner通过返回
bufio.NewScanner()读取整行且仅当遇到一个换行符返回的东西(如由定义的
bufio.ScanLines()函数)。
如果您执行的命令没有打印换行符,则不会立即返回其输出(仅当打印换行符,内部缓冲区已满或过程结束时)。
可能的解决方法
如果不能保证子进程打印换行符,但仍要流输出,则无法读取整行。一种解决方案是按单词阅读,甚至按字符(符文)阅读。您可以通过使用方法设置其他拆分功能来实现此目的
Scanner.Split():
scanner := bufio.NewScanner(stdout)scanner.Split(bufio.ScanRunes)
该
bufio.ScanRunes函数通过
runes
读取输入,因此
Scanner.Scan()只要有新
rune的可用,它将返回。
或手动读取而不使用
Scanner(在此示例中为逐字节):
oneByte := make([]byte, 1)for { _, err := stdout.Read(oneByte) if err != nil { break } fmt.Printf("%c", oneByte[0])}请注意,以上代码将错误地读取
runeUTF-8编码中的多个字节。要读取多个UTF-8字节的符文,我们需要更大的缓冲区:
oneRune := make([]byte, utf8.UTFMax)for { count, err := stdout.Read(oneRune) if err != nil { break } fmt.Printf("%s", oneRune[:count])}注意事项
进程具有用于标准输出和标准错误(通常为几KB大小)的默认缓冲区。如果某个进程写入标准输出或标准错误,它将进入相应的缓冲区。如果此缓冲区已满,
则将阻止 进一步的写入(在子进程中)。如果您没有阅读子进程的标准输出和标准错误,则如果缓冲区已满,则子进程可能会挂起。
因此,建议始终读取标准输出和子进程的错误。即使你知道该命令不 正常 写入其标准错误,如果出现一些错误,它可能会开始抛售错误信息到其标准错误。
编辑: 正如Dave
C所提到的,默认情况下,子进程的标准输出和错误流将被丢弃,如果不读取,将不会导致阻塞/挂起。但是,如果不读取错误流,您可能会在过程中错过一两件事。



