流式命令从 Goroutine 输出进度

一分耕耘，一分收获！既然打开了这篇文章《流式命令从 Goroutine 输出进度》，就坚持看下去吧！文中内容包含golang等等知识点...希望你能在阅读本文后，能真真实实学到知识或者帮你解决心中的疑惑，也欢迎大佬或者新人朋友们多留言评论，多给建议！谢谢！

问题内容

[流式命令输出进度](https://stackoverflow.com/questions/30725751/streaming-commands- output-progress)问题解决了长时间运行命令的打印进度问题。

我试图将打印代码放在 goroutine 中，但扫描仪声称已经EOF立即命中并且永远不会执行 for 块。

bufio.scan在第一次执行该方法时执行的代码Scan()是：

    // We cannot generate a token with what we are holding.
    // If we've already hit EOF or an I/O error, we are done.
    if s.err != nil {
        // Shut it down.
        s.start = 0
        s.end = 0
        return false
    }

如果我打印s.err输出是EOF.

我试图运行的代码是：

cmd := exec.Command("some", "command")
c := make(chan int, 1)

go func(cmd *exec.Cmd, c chan int) {
    stdout, _ := cmd.StdoutPipe()

    
<p>这个想法是启动 Goroutine，获取<code>cmd.stdout</code>，等待<code>cmd</code>启动，然后开始处理它的输出。</p>
<p>结果是长命令被执行并且程序等待其完成，但没有任何内容打印到终端。</p>
<p>知道为什么第一次<code>scanner.Scan()</code>调用时<code>stdout</code>已经达到了<code>EOF</code>吗？</p>
<h2 class="daan">
    正确答案
</h2>
<h3>有一些问题：</h3>

• 在读取所有数据之前关闭管道。
• 始终检查错误
• cmd.Start()之后开始c 并使用无缓冲通道c := make(chan struct{})

两个工作示例代码：

EOF1：等待使用通道，然后在使用后关闭管道defer func() { c ，就像这个工作示例代码：

package main

import (
    "bufio"
    "fmt"
    "os/exec"
)

func main() {
    cmd := exec.Command("Streamer")
    c := make(chan struct{})

    go run(cmd, c)

    c 
<hr><p>2：你也可以等待使用<code>sync.WaitGroup</code>，就像这个工作示例代码：</p>
<pre class="brush:go;toolbar:false">package main

import (
    "bufio"
    "fmt"
    "os/exec"
    "sync"
)

var wg sync.WaitGroup

func main() {
    cmd := exec.Command("Streamer")
    c := make(chan struct{})
    wg.Add(1)
    go func(cmd *exec.Cmd, c chan struct{}) {
        defer wg.Done()
        stdout, err := cmd.StdoutPipe()
        if err != nil {
            panic(err)
        }
        
<hr><p>和 Streamer 示例代码（仅用于测试）：</p>
<pre class="brush:go;toolbar:false">package main

import "fmt"
import "time"

func main() {
    for i := 0; i 
<hr><p>并查看<code>func (c *Cmd) StdoutPipe() (io.ReadCloser, error)</code> 文档：</p>
<blockquote>
<p>StdoutPipe 返回一个管道，该管道将在命令启动时连接到命令的标准输出。</p>
<p>Wait 会在看到命令退出后关闭管道，所以大多数调用者不需要自己关闭管道；但是，这意味着在管道的所有读取完成之前调用 Wait 是不正确的。同理，在使用
StdoutPipe 时调用 Run 是不正确的。有关惯用用法，请参见示例。</p>
</blockquote><p>今天关于《流式命令从 Goroutine 输出进度》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于golang的内容请关注golang学习网公众号！</p>