进程已输出内容但C# Process输出流读取阻塞问题

核心问题排查 #

大概率是KataGo将启动信息（如版本号）输出到了**标准错误流（stderr）**而非标准输出流（stdout），而你只重定向了stdout，导致stderr缓冲区满后进程阻塞；或者异步读取时未正确监听错误流。

解决方案 #

方案1：异步同时监听标准输出和错误流

这种方式能同时捕获两类输出，避免因单一流缓冲区溢出导致的阻塞：

using System;
using System.Diagnostics;

class Program
{
    static void Main(string[] args)
    {
        var kataGoProcess = new Process
        {
            StartInfo = new ProcessStartInfo
            {
                FileName = "KataGo.exe",
                Arguments = "gtp -model model.bin -config config.cfg", // 替换为你的实际参数
                UseShellExecute = false,
                RedirectStandardOutput = true,
                RedirectStandardError = true,
                CreateNoWindow = true,
                RedirectStandardInput = true // 如果需要发送GTP命令，必须开启
            },
            EnableRaisingEvents = true
        };

        // 绑定输出和错误流的回调
        kataGoProcess.OutputDataReceived += (sender, e) =>
        {
            if (!string.IsNullOrEmpty(e.Data))
                Console.WriteLine($"KataGo stdout: {e.Data}");
        };

        kataGoProcess.ErrorDataReceived += (sender, e) =>
        {
            if (!string.IsNullOrEmpty(e.Data))
                Console.WriteLine($"KataGo stderr: {e.Data}");
        };

        // 启动进程并开始异步读取
        kataGoProcess.Start();
        kataGoProcess.BeginOutputReadLine();
        kataGoProcess.BeginErrorReadLine();

        // 示例：发送GTP命令（比如询问版本）
        kataGoProcess.StandardInput.WriteLine("version");
        kataGoProcess.StandardInput.Flush();

        // 等待进程结束（按需调整，也可以用WaitForExitAsync）
        kataGoProcess.WaitForExit();
    }
}

方案2：同步读取（多线程处理双缓冲）

如果偏好同步读取，需要用线程分别处理stdout和stderr，防止单一流阻塞整个程序：

using System;
using System.Diagnostics;
using System.Threading;

class Program
{
    static void Main(string[] args)
    {
        var kataGoProcess = new Process
        {
            StartInfo = new ProcessStartInfo
            {
                FileName = "KataGo.exe",
                Arguments = "gtp -model model.bin -config config.cfg",
                UseShellExecute = false,
                RedirectStandardOutput = true,
                RedirectStandardError = true,
                CreateNoWindow = true,
                RedirectStandardInput = true
            }
        };

        kataGoProcess.Start();

        // 启动线程读取stdout
        var stdoutThread = new Thread(() =>
        {
            string line;
            while ((line = kataGoProcess.StandardOutput.ReadLine()) != null)
            {
                Console.WriteLine($"KataGo stdout: {line}");
            }
        });
        stdoutThread.Start();

        // 启动线程读取stderr
        var stderrThread = new Thread(() =>
        {
            string line;
            while ((line = kataGoProcess.StandardError.ReadLine()) != null)
            {
                Console.WriteLine($"KataGo stderr: {line}");
            }
        });
        stderrThread.Start();

        // 发送GTP命令示例
        kataGoProcess.StandardInput.WriteLine("version");
        kataGoProcess.StandardInput.Flush();

        // 等待进程结束并回收线程
        kataGoProcess.WaitForExit();
        stdoutThread.Join();
        stderrThread.Join();
    }
}

关键注意点 #

• 必须同时重定向StandardOutput和StandardError，并都做读取处理，否则任意一个流的缓冲区满都会导致KataGo进程阻塞。
• 如果需要和KataGo交互（发送GTP命令），必须开启RedirectStandardInput，并在发送命令后调用Flush()确保数据写入。
• 异步读取时务必调用BeginOutputReadLine()和BeginErrorReadLine()，否则回调不会触发。

内容的提问来源于stack exchange，提问作者Manuel