您将如何流式传输流程的输出？

Question

我相信我一般理解这样做的一种方式：

• 创建Command
• 使用Stdio::piped() 创建一对新的输出流
• 配置command.stdout()和command.stderr()
• 产生进程
• 创建一个新线程并将标准错误和标准输出传递给它
• 在远程线程中，不断轮询输入并将其写入输出流。
• 在主线程中，等待进程完成。

听起来对吗？

我的两个实际问题：

1. 有没有更简单的方法不涉及每个进程的“读取线程”？

2. 如果没有更简单的方法，Read::read() 需要 &mut self；你如何将它传递给远程线程？

请提供具体示例说明如何实际流式传输输出，而不仅仅是关于如何做的一般性建议...

更具体地说，这里是the default example of using spawn：

use std::process::Command;

let mut child = Command::new("/bin/cat")
                        .arg("file.txt")
                        .spawn()
                        .expect("failed to execute child");

let ecode = child.wait()
                 .expect("failed to wait on child");

assert!(ecode.success());

如何更改上面的示例以将 child 的输出流式传输到控制台，而不仅仅是等待退出代码？

Answer 1

虽然接受的答案是正确的，但它并没有涵盖非平凡的情况。

要流式输出并手动处理，请使用Stdio::piped() 并手动处理调用spawn 返回的子级的.stdout 属性，如下所示：

use std::process::{Command, Stdio};
use std::path::Path;
use std::io::{BufReader, BufRead};

pub fn exec_stream<P: AsRef<Path>>(binary: P, args: Vec<&'static str>) {
    let mut cmd = Command::new(binary.as_ref())
        .args(&args)
        .stdout(Stdio::piped())
        .spawn()
        .unwrap();

    {
        let stdout = cmd.stdout.as_mut().unwrap();
        let stdout_reader = BufReader::new(stdout);
        let stdout_lines = stdout_reader.lines();

        for line in stdout_lines {
            println!("Read: {:?}", line);
        }
    }

    cmd.wait().unwrap();
}

#[test]
fn test_long_running_process() {
    exec_stream("findstr", vec!("/s", "sql", "C:\\tmp\\*"));
}

另请参阅Merge child process stdout and stderr，了解同时捕获 stderr 和 stdout 的输出。

Answer 2

我很乐意接受任何生成长时间运行的进程并将输出流式传输到控制台的示例，无论以何种方式。

听起来你想要Stdio::inherit：

use std::process::{Command, Stdio};

fn main() {
    let mut cmd =
        Command::new("cat")
        .args(&["/usr/share/dict/web2"])
        .stdout(Stdio::inherit())
        .stderr(Stdio::inherit())
        .spawn()
        .unwrap();

    // It's streaming here

    let status = cmd.wait();
    println!("Exited with status {:?}", status);
}