使用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可能有效。