Пример производителя/потребителя с использованием Stream.Synchronized - Потребитель не получает никаких данных

Question

Я пытаюсь отправить байты между двумя действиями C#, используя Stream.Synchronized, чтобы обернуть 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

В потребителя мне нужно обратиться к началу потока:

 Action consumer =() => 
     { 
      int b; 

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

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

     }; 

Answer 2

Там в similar question on SO, которые могли бы дать ответы от некоторых людей.

Другие варианты реализации чего-либо подобного: PipeStream available at CodeProject, TransferStream from parallel-extensions-extras, или в некоторых случаях может работать только стандарт System.Collections.Concurrent.BlockingCollection.