如何在使用 IPC C# 时有效地从管道流读取

Question

我在下面写了我的程序的简化版本。进程 A 启动子进程（进程 B）。我使用匿名管道来写入有关在进程 B 上运行的方法的进度的信息。同时，我在进程 A 中有一个函数，它不断从流中读取，以查看管道中是否有新的更新。如果有，则更新流程 A 上的表单以反映进度。这按预期工作，但是我想知道是否有更好的方法来完成此操作，而无需不断检查流以查看进度是否有任何新的更新。

/////////////////
///Process A ////
/////////////////
public void LaunchProcessB()
{
    using (AnonymousPipeServerStream pipeServer = new AnonymousPipeServerStream(PipeDirection.In,
            HandleInheritability.Inheritable))
    {
        var _Process = new Process();
        _Process.StartInfo.FileName = exeString;
        _Process.StartInfo.Arguments = pipeServer.GetClientHandleAsString()
        _Process.StartInfo.RedirectStandardOutput = true;
        _Process.StartInfo.RedirectStandardInput = true;
        _Process.StartInfo.CreateNoWindow = true;
        _Process.StartInfo.UseShellExecute = false;
        _Process.Start(); //launches process B
        pipeServer.DisposeLocalCopyOfClientHandle();
        using (StreamReader sr = new StreamReader(pipeServer))
        {
            try
            {
                while (true)
                {
                    string temp = sr.ReadLine();
                    if (temp == null) break;
                    int result;
                    if (Int32.TryParse(temp, out result))
                        ShowDocumentProgress(result);
                    else ShowProgress(temp);
                }
            }
            catch (Exception)
            {
                //error occured when reading from stream.
            }
        }
        if (!_Process.Responding && !_Process.HasExited)
        {
            _Process.Kill();
            return;
        }
        _Process.WaitForExit(10000);
    }
}
private void ShowProgressPercent(int percentage)
{
    if (percentage > currentPercentage)
    {
        progressBar.Value = percentage;
    }
}
private void ShowProgress(string progressString)
{
    labelMessage.Text = progressString;
}

/////////////////
///Process B ////
/////////////////
private StreamWriter _progressWriter;
private PipeStream _progressPipe;
static int Main(string[] args)
{
    using (progressPipe = new AnonymousPipeClientStream(PipeDirection.Out, args[0]))
    using (_progressWriter = new StreamWriter(_progressPipe))   
    {
        RunLongProcess()
    }
}
private void RunLongProcess() 
{
    //attaches events to PercentProgress and StageProgress methods.  
}
private void PercentProgress(int percentage)
{
    _progressWriter.WriteLine(percentage.ToString());
    _progressPipe.WaitForPipeDrain();
}
private void StageProgress(string stage) 
{
    _progressWriter.WriteLine(stage);
    _progressPipe.WaitForPipeDrain();
}

Answer 1

while 条件不是必需的。只需读取直到 temp 为空。这是流的结束信号。

使这成为一个while(true)循环。

我认为您还需要添加异常处理以捕获终止和切断管道的进程。 !_Process.HasExited && pipeServer.IsConnected是不够的，因为它可能是真的，但在测试后立即切换到假。

我还会在最后添加一个WaitForExit，以确保系统在您继续之前处于静止状态。