.NET/C#中AnonymousPipeServerStream与AnonymousPipeClientStream通信异常

线程阻塞的核心原因是客户端的CopyTo方法会一直等待管道的结束信号（EOF），但服务器写完数据后没有发送这个信号，导致客户端线程卡在pipein.CopyTo(x)处无限等待，永远执行不到后续的输出代码，最终主线程在t.Join()处持续阻塞。

要解决这个问题，需要在服务器写完数据后，明确告知客户端数据传输完成：

1. 调用pipeout.WaitForPipeDrain()确保所有数据都已写入管道；
2. 调用pipeout.DisposeLocalCopyOfClientHandle()释放服务器端持有的客户端句柄副本，触发管道的结束信号，让客户端的CopyTo方法正常退出。

修改后的代码如下：

using (AnonymousPipeServerStream pipeout = new AnonymousPipeServerStream(PipeDirection.Out))
{
    using (AnonymousPipeClientStream pipein = new AnonymousPipeClientStream(PipeDirection.In,
        pipeout.GetClientHandleAsString()))
    {
        Thread t = new Thread(() =>
        {
            using (MemoryStream x = new MemoryStream())
            {
                pipein.CopyTo(x);
                string text2 = Encoding.UTF8.GetString(x.ToArray());
                Console.WriteLine("> " + text2);
            }
        });
        t.Start();

        string text = "hello !";
        using (MemoryStream x = new MemoryStream(Encoding.UTF8.GetBytes(text)))
        {
            x.CopyTo(pipeout);
        }

        // 新增：确保数据全部发送，并触发管道结束信号
        pipeout.WaitForPipeDrain();
        pipeout.DisposeLocalCopyOfClientHandle();

        t.Join();
    }               
}

• 原代码中res变量定义在主线程，线程内赋值存在潜在线程安全风险，修改后直接在线程内将MemoryStream转换为字符串，规避了该问题；
• 如果用Task替代Thread，代码会更简洁且符合现代.NET异步编程习惯，但核心逻辑的修改点一致。

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