栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 面试经验 > 面试问答

流命令输出进度

面试问答 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

流命令输出进度

您发布的代码有效(执行了合理的命令)。

这是用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
函数通过
rune
s
读取输入,因此
Scanner.Scan()
只要有新
rune
的可用,它将返回。

或手动读取而不使用

Scanner
(在此示例中为逐字节):

oneByte := make([]byte, 1)for {    _, err := stdout.Read(oneByte)    if err != nil {        break    }    fmt.Printf("%c", oneByte[0])}

请注意,以上代码将错误地读取

rune
UTF-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所提到的,默认情况下,子进程的标准输出和错误流将被丢弃,如果不读取,将不会导致阻塞/挂起。但是,如果不读取错误流,您可能会在过程中错过一两件事。



转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/413077.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号