使用 Stream.Synchronized 的生产者/消费者示例 - 消费者没有获取任何数据

Question

我正在尝试使用Stream.Synchronized 在两个 C# 操作之间发送字节以包装 MemoryStream。消费者每次执行 ReadByte 时，总是得到一个 -1，表示流已关闭。当我逐步使用调试器时，生产者正在调用 WriteByte。我从来没有得到任何关于消费者行为的数据。

    static void Main(string[] args)
    {
        var memStream = new MemoryStream(100);

        Stream dataStream = Stream.Synchronized(memStream);

        Action producer = () =>
        {
            for (int i = 0; i < 256; i++)
            {
                dataStream.WriteByte(Convert.ToByte(i));
                dataStream.Flush();
            }


        };

        int total = 0;
        Action consumer = () =>
        {
            int b;
            do
            {
                b = dataStream.ReadByte();
                if (b>=0)
                    total += b;
            }
            while (b < 255);

        };

        Parallel.Invoke(producer, consumer);

        Console.Out.WriteLine("Total = {0}", total);
    }

Answer 1

有一个similar question on SO 可能会提供一些人的答案。

实现此类功能的其他选项是PipeStream available at CodeProject、TransferStream from parallel-extensions-extras，或者在某些情况下可能只是标准的System.Collections.Concurrent.BlockingCollection。

Answer 2

在消费者中我需要寻找到流的开头：

        Action consumer = () =>
        {
            int b;

            dataStream.Seek(0, SeekOrigin.Begin);
            do
            {

                b = dataStream.ReadByte();
                if (b >= 0)
                    total += b;
            }
            while (b < 255);

        };